Package com.couchbase.client.core.msg.query

Class QueryResponse

java.lang.Object

com.couchbase.client.core.msg.BaseResponse

com.couchbase.client.core.msg.query.QueryResponse

All Implemented Interfaces:

ChunkedResponse<QueryChunkHeader,QueryChunkRow,QueryChunkTrailer>, Response

public class QueryResponse
extends BaseResponse
implements ChunkedResponse<QueryChunkHeader,QueryChunkRow,QueryChunkTrailer>

Constructor Summary

Constructors

Constructor	Description
QueryResponse(ResponseStatus status, QueryChunkHeader header, reactor.core.publisher.Flux<QueryChunkRow> rows, reactor.core.publisher.Mono<QueryChunkTrailer> trailer)

Method Summary

Modifier and Type	Method	Description
static RuntimeException	errorIncompleteResponse()
static RuntimeException	errorProfileNotPresent()
static RuntimeException	errorSignatureNotPresent()
static RuntimeException	errorWarningsNotPresent()
QueryChunkHeader	header()	Returns the header for this response, immediately available.
reactor.core.publisher.Flux<QueryChunkRow>	rows()	Returns the rows for this response, available pushed as they come streaming in.
String	toString()
reactor.core.publisher.Mono<QueryChunkTrailer>	trailer()	Returns the trailer for this response, available at the end of the response eventually.

Methods inherited from class com.couchbase.client.core.msg.BaseResponse

status

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.couchbase.client.core.msg.Response

status

Constructor Details

QueryResponse

public QueryResponse(ResponseStatus status,
 QueryChunkHeader header,
 reactor.core.publisher.Flux<QueryChunkRow> rows,
 reactor.core.publisher.Mono<QueryChunkTrailer> trailer)

Method Details

errorSignatureNotPresent

public static RuntimeException errorSignatureNotPresent()

errorWarningsNotPresent

public static RuntimeException errorWarningsNotPresent()

errorProfileNotPresent

public static RuntimeException errorProfileNotPresent()

errorIncompleteResponse

public static RuntimeException errorIncompleteResponse()

header

public QueryChunkHeader header()

Description copied from interface: ChunkedResponse

Returns the header for this response, immediately available.

Specified by:

header in interface ChunkedResponse<QueryChunkHeader,QueryChunkRow,QueryChunkTrailer>

rows

public reactor.core.publisher.Flux<QueryChunkRow> rows()

Description copied from interface: ChunkedResponse

Returns the rows for this response, available pushed as they come streaming in.

Specified by:

rows in interface ChunkedResponse<QueryChunkHeader,QueryChunkRow,QueryChunkTrailer>

trailer

public reactor.core.publisher.Mono<QueryChunkTrailer> trailer()

Description copied from interface: ChunkedResponse

Returns the trailer for this response, available at the end of the response eventually.

Specified by:

trailer in interface ChunkedResponse<QueryChunkHeader,QueryChunkRow,QueryChunkTrailer>

toString

public String toString()

Overrides:

toString in class BaseResponse