Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_CONNECTION_NAME |
Constructor and Description |
---|
BucketStreamAggregator(com.couchbase.client.core.ClusterFacade core,
String bucket) |
BucketStreamAggregator(String name,
com.couchbase.client.core.ClusterFacade core,
String bucket)
Create BucketStreamAggregator instance
|
Modifier and Type | Method and Description |
---|---|
Observable<com.couchbase.client.core.message.dcp.DCPRequest> |
feed()
Opens a DCP stream with default name and returns the feed of changes from beginning.
|
Observable<com.couchbase.client.core.message.dcp.DCPRequest> |
feed(com.couchbase.client.core.dcp.BucketStreamAggregatorState aggregatorState)
Opens a DCP stream and returns the feed of changes.
|
Observable<com.couchbase.client.core.dcp.BucketStreamAggregatorState> |
getCurrentState()
Retrieve current state of the partitions.
|
String |
name() |
public static String DEFAULT_CONNECTION_NAME
public BucketStreamAggregator(com.couchbase.client.core.ClusterFacade core, String bucket)
public String name()
public Observable<com.couchbase.client.core.message.dcp.DCPRequest> feed()
DCPRequest
s.public Observable<com.couchbase.client.core.message.dcp.DCPRequest> feed(com.couchbase.client.core.dcp.BucketStreamAggregatorState aggregatorState)
aggregatorState
- state objectDCPRequest
s.public Observable<com.couchbase.client.core.dcp.BucketStreamAggregatorState> getCurrentState()
Copyright © 2015 Couchbase, Inc.