'Dispatch IO events to _handle_recv, etc.'

def _handle_events(self, fd=0, events=0):

    zmq_events = self._shadow_sock.EVENTS
    if (zmq_events & _zmq.POLLIN):
        self._handle_recv()
    if (zmq_events & _zmq.POLLOUT):
        self._handle_send()
    self._schedule_remaining_events()
