@InterfaceStability.Experimental @InterfaceAudience.Private public class StreamRequestResponse extends AbstractDCPResponse
Constructor and Description |
---|
StreamRequestResponse(ResponseStatus status,
Observable<DCPRequest> stream,
List<FailoverLogEntry> failoverLog,
CouchbaseRequest request,
long rollbackToSequenceNumber)
Sets the required properties for the response.
|
Modifier and Type | Method and Description |
---|---|
List<FailoverLogEntry> |
failoverLog() |
long |
getRollbackToSequenceNumber() |
Observable<DCPRequest> |
stream() |
partition, partition
creationTime, request, status, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
request, status
creationTime
public StreamRequestResponse(ResponseStatus status, Observable<DCPRequest> stream, List<FailoverLogEntry> failoverLog, CouchbaseRequest request, long rollbackToSequenceNumber)
Sets the required properties for the response.
status
- the status of the response.stream
- observable, emitting DCP messages from the serverfailoverLog
- the list of failover log entries or null if response status is not successrollbackToSequenceNumber
- if server instruct to rollback client’s state, this field contains sequence number to userequest
- public Observable<DCPRequest> stream()
public List<FailoverLogEntry> failoverLog()
public long getRollbackToSequenceNumber()
Copyright © 2015 Couchbase, Inc.. All rights reserved.