@ -44,6 +44,11 @@ public interface RBloomFilter<T> extends RExpirable {
double getFalseProbability();
/**
* Returns number of bits in Redis memory required by this instance
*
* @return number of bits
*/
long getSize();
int getHashIterations();
@ -17,6 +17,11 @@ package org.redisson.client;
import org.redisson.client.protocol.pubsub.PubSubType;
* @author Nikita Koksharov
public class BaseRedisPubSubListener implements RedisPubSubListener<Object> {
@Override
@ -18,6 +18,12 @@ package org.redisson.client;
import org.redisson.api.listener.MessageListener;
* @param <V> value type
public interface RedisPubSubListener<V> extends MessageListener<V> {
boolean onStatus(PubSubType type, String channel);
@ -21,6 +21,11 @@ import io.netty.util.concurrent.Future;
import io.netty.util.concurrent.ImmediateEventExecutor;
import io.netty.util.concurrent.Promise;
public class SubscribeListener extends BaseRedisPubSubListener {
Promise<Void> promise = ImmediateEventExecutor.INSTANCE.newPromise();