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