Toggle navigation
Home
long to org.neo4j.coreedge.catchup.CatchupResult
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'neo4j'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Cascading Type Change (Different)
CompletableFuture<Long>
to
CompletableFuture<CatchupResult>
CatchUpResponseAdaptor<Long>
to
CatchUpResponseAdaptor<CatchupResult>
Add or Remove Method invocation
response.isSuccess()
to
response.status()
signal.complete(response.lastTransactionIdSent())
to
signal.complete(response.status())
signal.completeExceptionally(new NoSuchTransactionException(startTxId))
to
signal.complete(response.status())
Update Anonymous class
{ @Override public void onTxPullResponse( CompletableFuture<Long> signal, TxPullResponse response){ txPullResponseListener.onTxReceived(response); } @Override public void onTxStreamFinishedResponse( CompletableFuture<Long> signal, TxStreamFinishedResponse response){ if (response.isSuccess()) { signal.complete(response.lastTransactionIdSent()); } else { signal.completeExceptionally(new NoSuchTransactionException(startTxId)); } } }
to
{ @Override public void onTxPullResponse( CompletableFuture<CatchupResult> signal, TxPullResponse response){ txPullResponseListener.onTxReceived(response); } @Override public void onTxStreamFinishedResponse( CompletableFuture<CatchupResult> signal, TxStreamFinishedResponse response){ signal.complete(response.status()); } }