java.util.concurrent.CompletableFuture to reactor.core.publisher.Mono
No. of Instances - 287
No. of Commits - 13
No. of Projects - {'james-project'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> External
Mapping:
- Rename Method invocation
- thenApply to map
- thenRunAsync to doOnTerminate
- executeReturnApplied to executeReturnAppliedReactor
- thenApply to map
- thenCompose to flatMap
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- execute to executeReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- execute to executeReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- execute to executeReactor
- executeVoid to executeVoidReactor
- execute to executeReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- thenCombine to zipWith
- executeVoid to executeVoidReactor
- thenCombine to zipWith
- thenCombine to zipWith
- executeSingleRow to executeSingleRowReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- thenCombine to zipWith
- execute to executeReactor
- thenApply to flatMap
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- thenApply to map
- thenApply to flatMap
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- execute to executeSingleRowReactor
- executeVoid to executeVoidReactor
- thenCompose to flatMap
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- executeVoid to executeVoidReactor
- thenApply to map
- thenApply to map
- Other
- executor.executeVoid(insertOne.bind().setTimestamp(BROWSE_START,Date.from(sliceStart)).setString(QUEUE_NAME,mailQueueName.asString())) to executor.executeVoid(insertOne.bind().setTimestamp(BROWSE_START,Date.from(sliceStart)).setString(QUEUE_NAME,mailQueueName.asString()))
- executor.executeVoid(insert.bind().setString(QUEUE_NAME,enqueuedItem.getMailQueueName().asString()).setTimestamp(TIME_RANGE_START,Date.from(slicingContext.getTimeRangeStart())).setInt(BUCKET_ID,slicingContext.getBucketId().getValue()).setTimestamp(ENQUEUED_TIME,Date.from(enqueuedItem.getEnqueuedTime())).setString(MAIL_KEY,mail.getName()).setString(HEADER_BLOB_ID,mimeMessagePartsId.getHeaderBlobId().asString()).setString(BODY_BLOB_ID,mimeMessagePartsId.getBodyBlobId().asString()).setString(STATE,mail.getState()).setString(SENDER,mail.getMaybeSender().asString(null)).setList(RECIPIENTS,asStringList(mail.getRecipients())).setString(ERROR_MESSAGE,mail.getErrorMessage()).setString(REMOTE_ADDR,mail.getRemoteAddr()).setString(REMOTE_HOST,mail.getRemoteHost()).setTimestamp(LAST_UPDATED,mail.getLastUpdated()).setMap(ATTRIBUTES,toRawAttributeMap(mail)).setMap(PER_RECIPIENT_SPECIFIC_HEADERS,toHeaderMap(cassandraTypesProvider,mail.getPerRecipientSpecificHeaders()))) to executor.executeVoid(insert.bind().setString(QUEUE_NAME,enqueuedItem.getMailQueueName().asString()).setTimestamp(TIME_RANGE_START,Date.from(slicingContext.getTimeRangeStart())).setInt(BUCKET_ID,slicingContext.getBucketId().getValue()).setTimestamp(ENQUEUED_TIME,Date.from(enqueuedItem.getEnqueuedTime())).setString(MAIL_KEY,mail.getName()).setString(HEADER_BLOB_ID,mimeMessagePartsId.getHeaderBlobId().asString()).setString(BODY_BLOB_ID,mimeMessagePartsId.getBodyBlobId().asString()).setString(STATE,mail.getState()).setString(SENDER,mail.getMaybeSender().asString(null)).setList(RECIPIENTS,asStringList(mail.getRecipients())).setString(ERROR_MESSAGE,mail.getErrorMessage()).setString(REMOTE_ADDR,mail.getRemoteAddr()).setString(REMOTE_HOST,mail.getRemoteHost()).setTimestamp(LAST_UPDATED,mail.getLastUpdated()).setMap(ATTRIBUTES,toRawAttributeMap(mail)).setMap(PER_RECIPIENT_SPECIFIC_HEADERS,toHeaderMap(cassandraTypesProvider,mail.getPerRecipientSpecificHeaders())))
- executor.executeVoid(updateOne.bind().setTimestamp(BROWSE_START,Date.from(sliceStart)).setString(QUEUE_NAME,mailQueueName.asString())) to executor.executeVoid(updateOne.bind().setTimestamp(BROWSE_START,Date.from(sliceStart)).setString(QUEUE_NAME,mailQueueName.asString()))
- executor.executeVoid(insertOne.bind().setString(QUEUE_NAME,mailQueueName.asString()).setString(MAIL_KEY,mailKey.getMailKey())) to executor.executeVoid(insertOne.bind().setString(QUEUE_NAME,mailQueueName.asString()).setString(MAIL_KEY,mailKey.getMailKey()))
- executor.executeReturnExists(selectOne.bind().setString(QUEUE_NAME,mailQueueName.asString()).setString(MAIL_KEY,mailKey.getMailKey())) to executor.executeReturnExists(selectOne.bind().setString(QUEUE_NAME,mailQueueName.asString()).setString(MAIL_KEY,mailKey.getMailKey()))
- CompletableFuture.completedFuture(success) to false
- blobStore.readBytes(blobIdFactory.from(row.getString(field))) to blobStore.readBytes(blobIdFactory.from(row.getString(field)))
- resultSet -> getAcl(cassandraId,resultSet) to MailboxACL.EMPTY
- Add or Remove Method invocation
- thenApply to next
- thenApply to map
- thenApply to map
- truncateIfNeeded(executor,name,resultSet) to Mono.fromFuture(executor.execute(QueryBuilder.truncate(name)))
- thenCompose to flatMap
- thenApply to flatMap
- thenCompose to flatMap
- thenApply to then
- thenApply to defer
- activateNewScript.join() to activateNewScript.blockOptional().isPresent()
- nextUid to cache
- getScript to cache
- nextModSeq to cache
- sizeDifference.join() to sizeDifference.block()
- scriptNameOptional.map(activeScriptInfo -> updateScriptActivation(user,activeScriptInfo.getName(),false).<Void>thenApply(any -> null)).orElse(CompletableFuture.completedFuture(null)) to updateScriptActivation(user,activeScriptInfo.getName(),false).then()
- thenCompose to flatMap
- thenApply to map
- thenApply to hasElement
- thenApply to switchIfEmpty
- thenCompose to then
- thenApply to switchIfEmpty
- contentFuture to buildContentRetriever(fetchType,row)
- thenCompose to flatMap
- thenApply to thenReturn
- thenCompose to flatMap
- thenApply to switchIfEmpty
- mailboxId.map(cassandraId -> cassandraAsyncExecutor.execute(select.bind().setUUID(MESSAGE_ID,messageId.get()).setUUID(MAILBOX_ID,cassandraId.asUuid()))) to mailboxId.map(cassandraId -> cassandraAsyncExecutor.executeReactor(select.bind().setUUID(MESSAGE_ID,messageId.get()).setUUID(MAILBOX_ID,cassandraId.asUuid())))
- cassandraAsyncExecutor.execute(selectAll.bind().setUUID(MESSAGE_ID,messageId.get())) to cassandraAsyncExecutor.executeReactor(selectAll.bind().setUUID(MESSAGE_ID,messageId.get()))
- composedMessageIds.map(this::deleteIds).reduce((f1,f2) -> CompletableFuture.allOf(f1,f2)) to imapUidDAO.retrieve(messageId,mailboxId).flatMap(this::deleteIds)
- thenCompose to then
- assertThat(blobIdFuture) to assertThat(blobIdFuture.toFuture())
- assertThat(resultFuture) to assertThat(resultFuture.toFuture())
- assertThat(blobIdFuture) to assertThat(blobIdFuture.toFuture())
- thenApply to zipWith
- toFuture to map
- toFuture to saveAsMono
- cassandraAsyncExecutor.executeVoid(boundWriteStatement(message,pair)) to cassandraAsyncExecutor.executeVoidReactor(boundWriteStatement(message,pair))
- thenCompose to then
- toFuture to save
- thenApply to map
- thenCombine to switchIfEmpty
- toFuture to storeMail
- toFuture to map
- thenApply to switchIfEmpty
- thenApply to map
- hasUserQuota.thenCombine(hasGlobalQuota,(a,b) -> a || b) to hasUserQuota.zipWith(hasGlobalQuota,(a,b) -> a || b)
- CompletableFuture.runAsync(server::stop) to Mono.fromRunnable(server::stop)
- assertThatThrownBy(() -> blobStoreOperation.apply(blobStoreThrowsException)) to assertThatThrownBy(() -> blobStoreOperation.apply(blobStoreThrowsException).block())
- hasUserQuota.thenCombine(hasGlobalQuota,(a,b) -> a || b) to hasUserQuota.zipWith(hasGlobalQuota,(a,b) -> a || b)
- Cascading Type Change (Similar)
- CompletableFuture<Optional<MessageUid>> to Mono<MessageUid>
- CompletableFuture<Optional<Script>> to Mono<Script>
- CompletableFuture<Optional<Long>> to Mono<Long>
- CompletableFuture<Boolean> to Mono<Boolean>
- Rename Variable