code: def stream(self):
          '''
          Return the current zmqstream, creating one if necessary
          '''
          if not hasattr(self, '_stream'):
              self._stream = zmq.eventloop.zmqstream.ZMQStream(self._socket, io_loop=self.io_loop)
          return self._streaf stream(self):
          '''
          Return the current zmqstream, creating one if necessary
          '''
          if not hasattr(self, '_stream'):
              self._stream = zmq.eventloop.zmqstream.ZMQStream(self._socket, io_loop=self.io_loop)
          return self._stream
docs: Return the current zmqstream, creating one if necessary