Details
-
Bug
-
Resolution: Fixed
-
Major
-
0.8.0
-
None
Description
By default, ClientEnvironment constructs a DefaultEventBus (from couchbase-jvm-core) object to wrap around the subject used for system messages (passed to the library user using the systemEventHandler callback). DefaultEventBus.get() uses .onBackpressureDrop() to avoid backpressure situations, which doesn't seem desirable here; it should not drop things like StreamEndEvent-s which will never be sent again.
Source: https://github.com/couchbaselabs/java-dcp-client/issues/33