Toggle navigation
Home
org.redisson.api.RBlockingQueue to org.redisson.misc.RPromise
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'redisson'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Update Anonymous class
{ @Override public void operationComplete( Future<Boolean> future) throws Exception { if (!future.isSuccess()) { promise.tryFailure(future.cause()); return; } if (future.getNow()) { RFuture<RemoteServiceAck> pollFuture=responseQueue.pollAsync(); pollFuture.addListener(new FutureListener<RemoteServiceAck>(){ @Override public void operationComplete( Future<RemoteServiceAck> future) throws Exception { if (!future.isSuccess()) { promise.tryFailure(future.cause()); return; } promise.trySuccess(future.getNow()); } } ); } else { promise.trySuccess(null); } } }
to
{ @Override public void operationComplete( Future<Boolean> future) throws Exception { if (!future.isSuccess()) { promise.tryFailure(future.cause()); return; } if (future.getNow()) { pollFuture.addListener(new FutureListener<RemoteServiceAck>(){ @Override public void operationComplete( Future<RemoteServiceAck> future) throws Exception { if (!future.isSuccess()) { promise.tryFailure(future.cause()); return; } promise.trySuccess(future.getNow()); } } ); } else { promise.trySuccess(null); } } }
Rename Variable
responseQueue
to
pollFuture