environment/lib/python2.7/site-packages/IPython/parallel/client/client.py
def spin(self):
        """Flush any registration notifications and execution results
        waiting in the ZMQ queue.
        """
        if self._notification_socket:
            self._flush_notifications()
        if self._iopub_socket:
            self._flush_iopub(self._iopub_socket)
        if self._mux_socket:
            self._flush_results(self._mux_socket)
        if self._task_socket:
            self._flush_results(self._task_socket)
        if self._control_socket:
            self._flush_control(self._control_socket)
        if self._query_socket:
            self._flush_ignored_hub_replies()
def spin(self):
        """Flush any registration notifications and execution results
        waiting in the ZMQ queue.
        """
        if self._notification_socket:
            self._flush_notifications()
        if self._iopub_socket:
            self._flush_iopub(self._iopub_socket)
        if self._mux_socket:
            self._flush_results(self._mux_socket)
        if self._task_socket:
            self._flush_results(self._task_socket)
        if self._control_socket:
            self._flush_control(self._control_socket)
        if self._query_socket:
            self._flush_ignored_hub_replies()
def spin ( self ) : if self . _notification_socket : self . _flush_notifications ( ) if self . _iopub_socket : self . _flush_iopub ( self . _iopub_socket ) if self . _mux_socket : self . _flush_results ( self . _mux_socket ) if self . _task_socket : self . _flush_results ( self . _task_socket ) if self . _control_socket : self . _flush_control ( self . _control_socket ) if self . _query_socket : self . _flush_ignored_hub_replies ( )
Flush any registration notifications and execution results
        waiting in the ZMQ queue.
Flush any registration notifications and execution results waiting in the ZMQ queue .