public void initialize(final ByteBuf responseContent, final ResponseStatus responseStatus,
                           final CouchbaseRequest request) {
        this.sentResponse = false;
        this.response = null;
        this.responseContent = responseContent;
        this.currentRequest = request;

        queryRowObservable = UnicastAutoReleaseSubject.create(ttl, TimeUnit.MILLISECONDS, scheduler);

        parser.initialize(responseContent);
        initialized = true;
    }
public void initialize ( final ByteBuf responseContent , final ResponseStatus responseStatus , final CouchbaseRequest request ) { this . sentResponse = false ; this . response = null ; this . responseContent = responseContent ; this . currentRequest = request ; queryRowObservable = UnicastAutoReleaseSubject . create ( ttl , TimeUnit . MILLISECONDS , scheduler ) ; parser . initialize ( responseContent ) ; initialized = true ; }
Initialize this parser for a response parsing cycle.


@param responseContent the raw content to parse from.
@param responseStatus the status of the response.
@param request the original request.