(self, type, buffer, offset, size)
| 4046 | pass |
| 4047 | |
| 4048 | def on_receive(self, type, buffer, offset, size): |
| 4049 | |
| 4050 | if type == OrderMessageModel.TYPE: |
| 4051 | # Attach the FBE stream to the proxy model |
| 4052 | self._ordermessage_model.attach_buffer(buffer, offset) |
| 4053 | assert self._ordermessage_model.verify(), "proto.OrderMessage validation failed!" |
| 4054 | |
| 4055 | fbe_begin = self._ordermessage_model.model.get_begin() |
| 4056 | if fbe_begin == 0: |
| 4057 | return False |
| 4058 | # Call proxy handler |
| 4059 | self.on_proxy_ordermessage(self._ordermessage_model, type, buffer, offset, size) |
| 4060 | self._ordermessage_model.model.get_end(fbe_begin) |
| 4061 | return True |
| 4062 | |
| 4063 | if type == BalanceMessageModel.TYPE: |
| 4064 | # Attach the FBE stream to the proxy model |
| 4065 | self._balancemessage_model.attach_buffer(buffer, offset) |
| 4066 | assert self._balancemessage_model.verify(), "proto.BalanceMessage validation failed!" |
| 4067 | |
| 4068 | fbe_begin = self._balancemessage_model.model.get_begin() |
| 4069 | if fbe_begin == 0: |
| 4070 | return False |
| 4071 | # Call proxy handler |
| 4072 | self.on_proxy_balancemessage(self._balancemessage_model, type, buffer, offset, size) |
| 4073 | self._balancemessage_model.model.get_end(fbe_begin) |
| 4074 | return True |
| 4075 | |
| 4076 | if type == AccountMessageModel.TYPE: |
| 4077 | # Attach the FBE stream to the proxy model |
| 4078 | self._accountmessage_model.attach_buffer(buffer, offset) |
| 4079 | assert self._accountmessage_model.verify(), "proto.AccountMessage validation failed!" |
| 4080 | |
| 4081 | fbe_begin = self._accountmessage_model.model.get_begin() |
| 4082 | if fbe_begin == 0: |
| 4083 | return False |
| 4084 | # Call proxy handler |
| 4085 | self.on_proxy_accountmessage(self._accountmessage_model, type, buffer, offset, size) |
| 4086 | self._accountmessage_model.model.get_end(fbe_begin) |
| 4087 | return True |
| 4088 | |
| 4089 | return False |
| 4090 | |
| 4091 | |
| 4092 | # Fast Binary Encoding proto final sender |
nothing calls this directly
no test coverage detected