Class YasjlAnalyticsDeferredResponseParser
- java.lang.Object
-
- com.couchbase.client.core.endpoint.analytics.parser.YasjlAnalyticsDeferredResponseParser
-
public class YasjlAnalyticsDeferredResponseParser extends Object
Analytics query response parser, based on yasjl.- Author:
- Subhashni Balakrishnan
-
-
Constructor Summary
Constructors Constructor Description YasjlAnalyticsDeferredResponseParser(rx.Scheduler scheduler, long ttl, CoreEnvironment env)
Create a newYasjlQueryResponseParser
.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.
-
-
-
Constructor Detail
-
YasjlAnalyticsDeferredResponseParser
public YasjlAnalyticsDeferredResponseParser(rx.Scheduler scheduler, long ttl, CoreEnvironment env)
Create a newYasjlQueryResponseParser
.- Parameters:
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.
-
-
Method Detail
-
isInitialized
public boolean isInitialized()
True if this parser is currently initialized and ready to parse a response.- Returns:
- true if initialized, false otherwise.
-
initialize
public void initialize(ByteBuf responseContent, ResponseStatus responseStatus, CouchbaseRequest request)
Initialize this parser for a response parsing cycle.- Parameters:
responseContent
- the raw content to parse from.responseStatus
- the status of the response.request
- the original request.
-
parse
public GenericAnalyticsResponse parse() throws Exception
Instruct the parser to run a new parsing cycle on the current response content.- Returns:
- the
GenericQueryResponse
if ready, null otherwise. - Throws:
Exception
- if the internal parsing can't complete.
-
finishParsingAndReset
public void finishParsingAndReset()
Instruct the parser to finish the parsing and reset its internal state, turning it back to uninitialized as well.
-
-