code: def listen(self, listen):
          
  
          listener = IStreamListener(listen)
          if listener not in self.listeners:
              self.listeners.append(listener)
docs: Attach an :class:`txtorcon.interface.IStreamListener` to this stream.
  
          See also :meth:`txtorcon.TorState.add_stream_listener` to
          listen to all streams.
  
          :param listen: something that knows
              :class:`txtorcon.interface.IStreamListener`