Package com.couchbase.client.core.transaction.util

Class MonoBridge<T>

java.lang.Object

com.couchbase.client.core.transaction.util.MonoBridge<T>

@Internal
public class MonoBridge<T>
extends Object

Protects against concurrent op cancellation.

In reactive, if have multiple concurrent ops, if one fails then all the others will just stop executing once the error is raised past them in the chain. As if concurrent ops are being done with concatMap/flatMap, once the FluxConcatMap operator gets onError, it calls cancel() on its internal stream.

To avoid this, on a ctx.insert(), a MonoBridge is returned to the lambda and the actual work is started on a separate chain, whose signals are forwarded to the MonoBridge. That chain is then protected from any cancellation events, which the MonoBridge will receive.

Since this work, a CANCEL signal should not appear internally, and is possible indicative of an internal bug if it does.

Constructor Summary

Constructors

Constructor	Description
MonoBridge(Mono<T> feedFrom, String dbg, Object syncer, CoreTransactionLogger logger)

Method Summary

Modifier and Type	Method	Description
Mono<T>	external()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MonoBridge

public MonoBridge(Mono<T> feedFrom,
 String dbg,
 Object syncer,
 @Nullable
 CoreTransactionLogger logger)

Method Details

external

public Mono<T> external()