public class YasjlAnalyticsResponseParser extends Object
Constructor and Description |
---|
YasjlAnalyticsResponseParser(rx.Scheduler scheduler,
long ttl,
CoreEnvironment env)
Create a new
YasjlQueryResponseParser . |
Modifier and Type | Method and Description |
---|---|
void |
finishParsingAndReset()
Instruct the parser to finish the parsing and reset its internal state, turning it
back to uninitialized as well.
|
void |
initialize(ByteBuf responseContent,
ResponseStatus responseStatus,
CouchbaseRequest request)
Initialize this parser for a response parsing cycle.
|
boolean |
isInitialized()
True if this parser is currently initialized and ready to parse a response.
|
GenericAnalyticsResponse |
parse()
Instruct the parser to run a new parsing cycle on the current response content.
|
public YasjlAnalyticsResponseParser(rx.Scheduler scheduler, long ttl, CoreEnvironment env)
YasjlQueryResponseParser
.scheduler
- the scheduler which should be used when computations are moved out.ttl
- the ttl used for the subjects until their contents are garbage collected.public boolean isInitialized()
public void initialize(ByteBuf responseContent, ResponseStatus responseStatus, CouchbaseRequest request)
responseContent
- the raw content to parse from.responseStatus
- the status of the response.request
- the original request.public GenericAnalyticsResponse parse() throws Exception
GenericQueryResponse
if ready, null otherwise.Exception
- if the internal parsing can't complete.public void finishParsingAndReset()
Copyright © 2021 Couchbase, Inc.. All rights reserved.