#NEWLINE# def __init__( self , link , speed ) : #NEWLINE# #INDENT# '\n        :param link: :class:`~snakemq.link.Link`\n        :param speed: maximum speed in bytes per second (for individual connection)\n        ' #NEWLINE# self . link = link #NEWLINE# self . speed = ( speed * 2 ) #NEWLINE# self . on_connect = link . on_connect #NEWLINE# self . on_disconnect = link . on_disconnect #NEWLINE# self . on_recv = link . on_recv #NEWLINE# self . on_ready_to_send = Callback ( ) #NEWLINE# self . on_loop_pass = Callback ( ) #NEWLINE# self . link . on_connect . add ( self . _on_connect ) #NEWLINE# self . link . on_disconnect . add ( self . _on_disconnect ) #NEWLINE# self . link . on_ready_to_send . add ( self . _on_ready_to_send ) #NEWLINE# self . link . on_loop_pass . add ( self . _on_loop_pass ) #NEWLINE# self . connections = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# self . stopped = set ( )