Class YasjlAnalyticsDeferredResponseParser


public class YasjlAnalyticsDeferredResponseParser
extends Object
Analytics query response parser, based on yasjl.
Subhashni Balakrishnan
  • Constructor Details

    • YasjlAnalyticsDeferredResponseParser

      public YasjlAnalyticsDeferredResponseParser​(rx.Scheduler scheduler, long ttl, CoreEnvironment env)
      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 Details

    • isInitialized

      public boolean isInitialized()
      True if this parser is currently initialized and ready to parse a response.
      true if initialized, false otherwise.
    • initialize

      public void initialize​(ByteBuf responseContent, ResponseStatus responseStatus, CouchbaseRequest request)
      Initialize this parser for a response parsing cycle.
      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.
      the GenericQueryResponse if ready, null otherwise.
      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.