public class DCPStream extends Object
Represents stream of incoming DCP messages.
Modifier and Type | Field and Description |
---|---|
String |
bucket |
int |
id |
PublishSubject<DCPRequest> |
subject |
Constructor and Description |
---|
DCPStream(int id,
String bucket)
Creates new
DCPStream instance. |
Modifier and Type | Method and Description |
---|---|
String |
bucket() |
PublishSubject<DCPRequest> |
subject() |
public final int id
public final String bucket
public final PublishSubject<DCPRequest> subject
public PublishSubject<DCPRequest> subject()
public String bucket()
Copyright © 2014 Couchbase, Inc.