(self, f, protocol_version, user_type_map, result_metadata, column_encryption_policy)
| 720 | self.kind = kind |
| 721 | |
| 722 | def recv(self, f, protocol_version, user_type_map, result_metadata, column_encryption_policy): |
| 723 | if self.kind == RESULT_KIND_VOID: |
| 724 | return |
| 725 | elif self.kind == RESULT_KIND_ROWS: |
| 726 | self.recv_results_rows(f, protocol_version, user_type_map, result_metadata, column_encryption_policy) |
| 727 | elif self.kind == RESULT_KIND_SET_KEYSPACE: |
| 728 | self.new_keyspace = read_string(f) |
| 729 | elif self.kind == RESULT_KIND_PREPARED: |
| 730 | self.recv_results_prepared(f, protocol_version, user_type_map) |
| 731 | elif self.kind == RESULT_KIND_SCHEMA_CHANGE: |
| 732 | self.recv_results_schema_change(f, protocol_version) |
| 733 | else: |
| 734 | raise DriverException("Unknown RESULT kind: %d" % self.kind) |
| 735 | |
| 736 | @classmethod |
| 737 | def recv_body(cls, f, protocol_version, user_type_map, result_metadata, column_encryption_policy): |
no test coverage detected