Package com.couchbase.client.core.io.netty.query

Class QueryChunkResponseParser

java.lang.Object

com.couchbase.client.core.io.netty.chunk.BaseChunkResponseParser<QueryChunkHeader,QueryChunkRow,QueryChunkTrailer>

com.couchbase.client.core.io.netty.query.QueryChunkResponseParser

All Implemented Interfaces:

ChunkResponseParser<QueryChunkHeader,QueryChunkRow,QueryChunkTrailer>

public class QueryChunkResponseParser
extends BaseChunkResponseParser<QueryChunkHeader,QueryChunkRow,QueryChunkTrailer>

Constructor Summary

Constructors

Constructor	Description
QueryChunkResponseParser()

Method Summary

Modifier and Type	Method	Description
protected void	doCleanup()	Give subclasses a chance to reset their state.
Optional<CouchbaseException>	error()	If the parser sees an error, it should fill this optional so that if the IO layer needs to fail the topmost future it will be passed in.
Optional<QueryChunkHeader>	header(boolean lastChunk)	Once the header is completely available, returns a non-absent value of it.
protected JsonStreamParser.Builder	parserBuilder()	Subclass implements this to return the "meat" of the decoding, the chunk parser.
void	signalComplete()	Called when the JSON stream has been parsed completely and successfully.

Methods inherited from class com.couchbase.client.core.io.netty.chunk.BaseChunkResponseParser

cleanup, completeRows, completeTrailer, decodingFailure, emitRow, endOfInput, failRows, feed, initialize, isHeaderComplete, markHeaderComplete, requestContext, responseHeader, rows, trailer, updateRequestContext, updateResponseHeader

Methods inherited from class java.lang.Object

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

Constructor Details

QueryChunkResponseParser

public QueryChunkResponseParser()

Method Details

doCleanup

protected void doCleanup()

Description copied from class: BaseChunkResponseParser

Give subclasses a chance to reset their state.

Specified by:

doCleanup in class BaseChunkResponseParser<QueryChunkHeader,QueryChunkRow,QueryChunkTrailer>

parserBuilder

protected JsonStreamParser.Builder parserBuilder()

Description copied from class: BaseChunkResponseParser

Subclass implements this to return the "meat" of the decoding, the chunk parser.

Specified by:

parserBuilder in class BaseChunkResponseParser<QueryChunkHeader,QueryChunkRow,QueryChunkTrailer>

header

public Optional<QueryChunkHeader> header(boolean lastChunk)

Description copied from interface: ChunkResponseParser

Once the header is completely available, returns a non-absent value of it.

It is important to provide a non-absent value even if some parts are optional because the related IO components will only proceed if a header is available eventually.

Parameters:

lastChunk - if we are currently parsing the last chunk.

error

public Optional<CouchbaseException> error()

Description copied from interface: ChunkResponseParser

If the parser sees an error, it should fill this optional so that if the IO layer needs to fail the topmost future it will be passed in.

signalComplete

public void signalComplete()

Description copied from class: BaseChunkResponseParser

Called when the JSON stream has been parsed completely and successfully.

Specified by:

signalComplete in class BaseChunkResponseParser<QueryChunkHeader,QueryChunkRow,QueryChunkTrailer>