java.util.concurrent.Future to java.util.concurrent.CompletableFuture
No. of Instances - 139
No. of Commits - 17
No. of Projects - {'orientdb', 'JGroups', 'AxonFramework', 'neo4j', 'che', 'failsafe', 'flink', 'Singularity', 'infinispan', 'camel', 'mpush'}
Hierarchy/Composition: T_SUPER_R
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
- executorService.submit(performUploadCallable(uploader,isFinished,false)) to CompletableFuture.supplyAsync(performUploadSupplier(uploader,isFinished,false),executorService)
- executor.submit(task) to CompletableFuture.runAsync(new OETLExtractorWorker(this,queue,counter),executor)
- rpcManager.invokeRemotelyAsync(Collections.singletonList(address),newStatePushCommand(cache,chunk),rpcManager.getDefaultRpcOptions(true)) to rpcManager.invokeCommand(address,newStatePushCommand(cache,chunk),SingleResponseCollector.validOnly(),rpcManager.getSyncRpcOptions()).toCompletableFuture()
- CompletableFuture.completedFuture(Collections.singletonMap(address,response)) to CompletableFuture.completedFuture(response)
- syncBackupCalls to Objects.requireNonNull(backupCalls)
- syncBackupCalls to Objects.requireNonNull(backupCalls)
- executor.submit(partitionProducers[i]) to CompletableFuture.supplyAsync(CheckedSupplier.unchecked(partitionProducers[i]::call),executor)
- executor.submit(new TestLocalInputChannelConsumer(i,parallelism,numberOfBuffersPerChannel,networkBuffers.createBufferPool(parallelism,parallelism),partitionManager,new TaskEventDispatcher(),partitionIds)) to CompletableFuture.supplyAsync(CheckedSupplier.unchecked(consumer::call),executor)
- body to createSetBodyProcessor(body)