Class BucketConsumer

java.lang.Object
rx.Subscriber<CouchbaseEvent>
com.couchbase.client.java.event.consumers.BucketConsumer
All Implemented Interfaces:
rx.Observer<CouchbaseEvent>, rx.Subscription

public class BucketConsumer
extends rx.Subscriber<CouchbaseEvent>
Consumes CouchbaseEvents and logs them into a bucket as JSON.
Since:
2.2.0
Author:
Michael Nitschinger