code: public void onNext(DataMessage<T, DataBuffer> value) {
      DataBuffer buffer = value.getBuffer();
      if (buffer != null) {
        mBufferRepository.offerBuffer(buffer, value.getMessage());
      }
      mObserver.onNext(value.getMessage());
    }
docs: Receives a message with data buffer from the stream.
  
  @param value the value passed to the stream