#NEWLINE# def __init__( self , socket , io = None , read_chunk_size = 4096 ) : #NEWLINE# #INDENT# self . socket = socket #NEWLINE# self . io = ( io or aio . loop ( ) ) #NEWLINE# self . _state = read_chunk_size . ERROR #NEWLINE# self . _read_chunk_size = read_chunk_size #NEWLINE# self . _wb = '' #NEWLINE# self . _reader = None #NEWLINE# self . _write_callback = None #NEWLINE# self . _close_callback = None #NEWLINE# self . io . add_handler ( socket . fileno ( ) , self . _handle , self . _state )