@ Override public void messageReceived ( IoSession session , Object buf ) { final IoSessionInputStream in = ( IoSessionInputStream ) session . getAttribute ( KEY_IN ) ; in . write ( ( IoBuffer ) buf ) ; }
Forwards read data to input stream .