#NEWLINE# def __init__( self , socket , session , loop ) : #NEWLINE# #INDENT# 'Create a channel.\n\n        Parameters\n        ----------\n        socket : :class:`zmq.Socket`\n            The ZMQ socket to use.\n        session : :class:`session.Session`\n            The session to use.\n        loop\n            A pyzmq ioloop to connect the socket to using a ZMQStream\n        ' #NEWLINE# super ( ThreadedZMQSocketChannel , self ) . __init__ ( ) #NEWLINE# self . socket = socket #NEWLINE# self . session = session #NEWLINE# self . ioloop = loop #NEWLINE# self . stream = zmqstream . ZMQStream ( self . socket , self . ioloop ) #NEWLINE# self . stream . on_recv ( loop . _handle_recv )