Toggle navigation
Home
java.util.concurrent.CompletableFuture to java.util.concurrent.CompletionStage
No. of Instances - 3
No. of Commits - 2
No. of Projects - {'java-driver'}
Hierarchy/Composition: R_SUPER_T
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
Add or Remove Method invocation
future
to
stage.toCompletableFuture()
rpcFuture
to
rpcFuture.toCompletableFuture()
revokeFuture
to
revokeFuture.toCompletableFuture()
((SuccessfulResponse)response).getResponseValue()
to
r.getResponseValue()
handleThrowable(new IllegalArgumentException("Unsupported response received: " + response),target)
to
handleThrowable(new IllegalArgumentException("Unsupported response received: " + r),target)
rpcManager.invokeRemotelyAsync(targets,command,syncRpcOptions)
to
remoteInvocation
syncIgnoreLeaversRpcOptions
to
rpcManager.getSyncRpcOptions()
syncIgnoreLeaversRpcOptions
to
rpcManager.getSyncRpcOptions()
rpcFuture
to
rpcFuture.toCompletableFuture()
revokeFuture
to
revokeFuture.toCompletableFuture()
defaultAsyncOptions
to
rpcManager.getSyncRpcOptions()
rpcFuture
to
rpcFuture.toCompletableFuture()
revokeFuture
to
revokeFuture.toCompletableFuture()
request.whenComplete((r,t) -> { if (t != null) { if (t instanceof TimeoutException) { throw asCompletionException(t); } else { triConsumer.accept(target,null,t); } } else { consumeResponse(r,target,v -> triConsumer.accept(target,(V)v,null),throwable -> triConsumer.accept(target,null,throwable)); } } )
to
request.toCompletableFuture().whenComplete((r,t) -> { if (t != null) { if (t instanceof TimeoutException) { throw asCompletionException(t); } else { triConsumer.accept(target,null,t); } } else { consumeResponse(r,target,v -> triConsumer.accept(target,(V)v,null),throwable -> triConsumer.accept(target,null,throwable)); } } )
request
to
request.toCompletableFuture()
CompletableFuture.allOf(ra)
to
remoteGetMany(ctx,command,remoteKeys)
Rename Variable
future
to
stage
completableFuture
to
rpcStage
future
to
request
future
to
request
invokeRemotelyAsync
to
invokeCommand
invokeRemotelyAsync
to
invokeCommand
invokeRemotelyAsync
to
invokeCommand
invokeRemotelyAsync
to
invokeCommand
invokeRemotelyAsync
to
invokeCommand
command
to
asyncCommand
completableFuture
to
completionStage
completableFuture
to
completionStage
Cascading Type Change (Similar)
CompletableFuture<Void>
to
CompletionStage<Void>
CompletableFuture<Void>
to
CompletionStage<Void>
Wrap or Un-wrap
execute
to
execute