(cls, f, protocol_version, *args)
| 1011 | |
| 1012 | @classmethod |
| 1013 | def recv_body(cls, f, protocol_version, *args): |
| 1014 | event_type = read_string(f).upper() |
| 1015 | if event_type in known_event_types: |
| 1016 | read_method = getattr(cls, 'recv_' + event_type.lower()) |
| 1017 | return cls(event_type=event_type, event_args=read_method(f, protocol_version)) |
| 1018 | raise NotSupportedError('Unknown event type %r' % event_type) |
| 1019 | |
| 1020 | @classmethod |
| 1021 | def recv_topology_change(cls, f, protocol_version): |
nothing calls this directly
no test coverage detected