(self, type, buffer, offset, size)
| 3972 | pass |
| 3973 | |
| 3974 | def on_receive(self, type, buffer, offset, size): |
| 3975 | |
| 3976 | if type == OrderMessageModel.TYPE: |
| 3977 | # Deserialize the value from the FBE stream |
| 3978 | self._ordermessage_model.attach_buffer(buffer, offset) |
| 3979 | assert self._ordermessage_model.verify(), "proto.OrderMessage validation failed!" |
| 3980 | (_, deserialized) = self._ordermessage_model.deserialize(self._ordermessage_value) |
| 3981 | assert (deserialized > 0), "proto.OrderMessage deserialization failed!" |
| 3982 | |
| 3983 | # Log the value |
| 3984 | if self.logging: |
| 3985 | message = str(self._ordermessage_value) |
| 3986 | self.on_receive_log(message) |
| 3987 | |
| 3988 | # Call receive handler with deserialized value |
| 3989 | self.on_receive_ordermessage(self._ordermessage_value) |
| 3990 | return True |
| 3991 | |
| 3992 | if type == BalanceMessageModel.TYPE: |
| 3993 | # Deserialize the value from the FBE stream |
| 3994 | self._balancemessage_model.attach_buffer(buffer, offset) |
| 3995 | assert self._balancemessage_model.verify(), "proto.BalanceMessage validation failed!" |
| 3996 | (_, deserialized) = self._balancemessage_model.deserialize(self._balancemessage_value) |
| 3997 | assert (deserialized > 0), "proto.BalanceMessage deserialization failed!" |
| 3998 | |
| 3999 | # Log the value |
| 4000 | if self.logging: |
| 4001 | message = str(self._balancemessage_value) |
| 4002 | self.on_receive_log(message) |
| 4003 | |
| 4004 | # Call receive handler with deserialized value |
| 4005 | self.on_receive_balancemessage(self._balancemessage_value) |
| 4006 | return True |
| 4007 | |
| 4008 | if type == AccountMessageModel.TYPE: |
| 4009 | # Deserialize the value from the FBE stream |
| 4010 | self._accountmessage_model.attach_buffer(buffer, offset) |
| 4011 | assert self._accountmessage_model.verify(), "proto.AccountMessage validation failed!" |
| 4012 | (_, deserialized) = self._accountmessage_model.deserialize(self._accountmessage_value) |
| 4013 | assert (deserialized > 0), "proto.AccountMessage deserialization failed!" |
| 4014 | |
| 4015 | # Log the value |
| 4016 | if self.logging: |
| 4017 | message = str(self._accountmessage_value) |
| 4018 | self.on_receive_log(message) |
| 4019 | |
| 4020 | # Call receive handler with deserialized value |
| 4021 | self.on_receive_accountmessage(self._accountmessage_value) |
| 4022 | return True |
| 4023 | |
| 4024 | return False |
| 4025 | |
| 4026 | |
| 4027 | # Fast Binary Encoding proto proxy |
nothing calls this directly
no test coverage detected