Package | Description |
---|---|
com.couchbase.client.core.dcp |
Modifier and Type | Method and Description |
---|---|
Observable<StreamRequestResponse> |
BucketStreamAggregator.open(BucketStreamAggregatorState aggregatorState)
Opens DCP stream for all vBuckets starting with given state.
|
Copyright © 2015 Couchbase, Inc.. All rights reserved.