

def dispatch(self, frame):
    "\n        Override the default dispatch since we don't need the rest of\n        the stack.\n        "
    if (frame.type() == HeartbeatFrame.type()):
        self.send_heartbeat()
    elif (frame.type() == MethodFrame.type()):
        if (frame.class_id == 10):
            cb = self._method_map.get(frame.method_id)
            if cb:
                method = self.clear_synchronous_cb(cb)
                method(frame)
            else:
                raise Channel.InvalidMethod('unsupported method %d on channel %d', frame.method_id, self.channel_id)
        else:
            raise Channel.InvalidClass('class %d is not supported on channel %d', frame.class_id, self.channel_id)
    else:
        raise Frame.InvalidFrameType('frame type %d is not supported on channel %d', frame.type(), self.channel_id)

dataset/ETHPy150Open agoragames/haigha/haigha/connection.py ConnectionChannel.dispatch/original