public class DCPConnection extends Object
Constructor and Description |
---|
DCPConnection(CoreEnvironment env,
String name,
String bucket) |
Modifier and Type | Method and Description |
---|---|
int |
addStream(String connectionName) |
String |
bucket() |
void |
inc(int delta) |
String |
name() |
void |
removeStream(int streamId) |
void |
reset() |
int |
streamsCount() |
Subject<DCPRequest,DCPRequest> |
subject() |
int |
totalReceivedBytes() |
public DCPConnection(CoreEnvironment env, String name, String bucket)
public int addStream(String connectionName)
public void removeStream(int streamId)
public int streamsCount()
public String name()
public String bucket()
public Subject<DCPRequest,DCPRequest> subject()
public int totalReceivedBytes()
public void inc(int delta)
public void reset()
Copyright © 2016 Couchbase, Inc.. All rights reserved.