@InterfaceStability.Experimental @InterfaceAudience.Public public class BucketStreamAggregator extends Object
Provides a higher level abstraction over a DCP stream.
The bucket is expected to be opened already when thefeed()
method is called.Constructor and Description |
---|
BucketStreamAggregator(ClusterFacade core,
String bucket) |
Modifier and Type | Method and Description |
---|---|
Observable<DCPRequest> |
feed()
Opens a DCP stream with default name and returns the feed of changes from beginning.
|
Observable<DCPRequest> |
feed(BucketStreamAggregatorState aggregatorState)
Opens a DCP stream and returns the feed of changes.
|
Observable<StreamRequestResponse> |
open(BucketStreamAggregatorState aggregatorState)
Opens DCP stream for all vBuckets starting with given state.
|
public BucketStreamAggregator(ClusterFacade core, String bucket)
public Observable<DCPRequest> feed()
Opens a DCP stream with default name and returns the feed of changes from beginning.
DCPRequest
s.public Observable<DCPRequest> feed(BucketStreamAggregatorState aggregatorState)
Opens a DCP stream and returns the feed of changes.
aggregatorState
- state objectDCPRequest
s.public Observable<StreamRequestResponse> open(BucketStreamAggregatorState aggregatorState)
Opens DCP stream for all vBuckets starting with given state. Use BucketStreamAggregatorState.BLANK to start from very beginning.
aggregatorState
- state objectCopyright © 2015 Couchbase, Inc.. All rights reserved.