code: private void parseQueryStatus(boolean lastChunk) {
          //some sections don't always come up, unlike status. Take this chance to close said sections' observables here.
          querySignatureObservable.onCompleted();
          queryRowObservable.onCompleted();
          queryErrorObservable.onCompleted();
  
          responseContent.markReaderIndex();
          responseContent.skipBytes(findNextChar(responseContent, '"') + 1);
          int endStatus = findNextChar(responseContent, '"');
          if (endStatus > -1) {
              ByteBuf resultSlice = responseContent.readSlice(endStatus);
              queryStatusObservable.onNext(resultSlice.toString(CHARSET));
              queryStatusObservable.onCompleted();
              sectionDone();
              queryParsingState = transitionToNextToken(lastChunk);
          } else {
              responseContent.resetReaderIndex();
              return; //need more data
          }
      }
docs: Last before the end of the stream, we can now parse the final result status
  (including full execution of the query).