CountableListener (Redisson 3.16.1 API)

java.lang.Object
- org.redisson.misc.CountableListener<T>

All Implemented Interfaces:: BiConsumer<Object,Throwable>

public class CountableListener<T>
extends Object
implements BiConsumer<Object,Throwable>

Author:: Nikita Koksharov

Field Summary

Fields
Modifier and Type Field Description

protected AtomicInteger counter

protected RPromise<T> result

protected T value

Constructor Summary

Constructors
Constructor	Description
`CountableListener()`
`CountableListener(RPromise<T> result, T value)`
`CountableListener(RPromise<T> result, T value, int count)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`accept(Object t, Throwable u)`
`void`	`decCounter()`
`protected void`	`onSuccess(T value)`
`void`	`setCounter(int newValue)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.BiConsumer
andThen

Field Detail

counter
```
protected final AtomicInteger counter
```

result
```
protected final RPromise<T> result
```

value
```
protected final T value
```

Constructor Detail

CountableListener
```
public CountableListener()
```

CountableListener

public CountableListener(RPromise<T> result,
                         T value)

CountableListener

public CountableListener(RPromise<T> result,
                         T value,
                         int count)

Method Detail

setCounter

public void setCounter(int newValue)

decCounter
```
public void decCounter()
```

onSuccess
```
protected void onSuccess(T value)
```

accept

public void accept(Object t,
                   Throwable u)

Specified by:: accept in interface BiConsumer<Object,Throwable>