code: def as_zmqstream(f):
      def wrapped(self, *args, **kwargs):
          socket = f(self, *args, **kwargs)
          return ZMQStream(socket, self.loop)
  
      return wrapped
  
file_path: catboost/contrib/python/jupyter-client/py2/jupyter_client/ioloop/manager.py
imports: from __future__ import absolute_import
  from zmq.eventloop import ioloop
  from zmq.eventloop.zmqstream import ZMQStream
  from traitlets import Instance, Type
  from jupyter_client.manager import KernelManager
  from .restarter import IOLoopKernelRestarter
label_desc: Use image node_id 1 for calling a global function with example usage: as_zmqstream(f) and returns: wrapped, ZMQStream