(self, type, buffer, offset, size)
| 4196 | pass |
| 4197 | |
| 4198 | def on_receive(self, type, buffer, offset, size): |
| 4199 | |
| 4200 | if type == OrderMessageFinalModel.TYPE: |
| 4201 | # Deserialize the value from the FBE stream |
| 4202 | self._ordermessage_model.attach_buffer(buffer, offset) |
| 4203 | assert self._ordermessage_model.verify(), "proto.OrderMessage validation failed!" |
| 4204 | (_, deserialized) = self._ordermessage_model.deserialize(self._ordermessage_value) |
| 4205 | assert (deserialized > 0), "proto.OrderMessage deserialization failed!" |
| 4206 | |
| 4207 | # Log the value |
| 4208 | if self.logging: |
| 4209 | message = str(self._ordermessage_value) |
| 4210 | self.on_receive_log(message) |
| 4211 | |
| 4212 | # Call receive handler with deserialized value |
| 4213 | self.on_receive_ordermessage(self._ordermessage_value) |
| 4214 | return True |
| 4215 | |
| 4216 | if type == BalanceMessageFinalModel.TYPE: |
| 4217 | # Deserialize the value from the FBE stream |
| 4218 | self._balancemessage_model.attach_buffer(buffer, offset) |
| 4219 | assert self._balancemessage_model.verify(), "proto.BalanceMessage validation failed!" |
| 4220 | (_, deserialized) = self._balancemessage_model.deserialize(self._balancemessage_value) |
| 4221 | assert (deserialized > 0), "proto.BalanceMessage deserialization failed!" |
| 4222 | |
| 4223 | # Log the value |
| 4224 | if self.logging: |
| 4225 | message = str(self._balancemessage_value) |
| 4226 | self.on_receive_log(message) |
| 4227 | |
| 4228 | # Call receive handler with deserialized value |
| 4229 | self.on_receive_balancemessage(self._balancemessage_value) |
| 4230 | return True |
| 4231 | |
| 4232 | if type == AccountMessageFinalModel.TYPE: |
| 4233 | # Deserialize the value from the FBE stream |
| 4234 | self._accountmessage_model.attach_buffer(buffer, offset) |
| 4235 | assert self._accountmessage_model.verify(), "proto.AccountMessage validation failed!" |
| 4236 | (_, deserialized) = self._accountmessage_model.deserialize(self._accountmessage_value) |
| 4237 | assert (deserialized > 0), "proto.AccountMessage deserialization failed!" |
| 4238 | |
| 4239 | # Log the value |
| 4240 | if self.logging: |
| 4241 | message = str(self._accountmessage_value) |
| 4242 | self.on_receive_log(message) |
| 4243 | |
| 4244 | # Call receive handler with deserialized value |
| 4245 | self.on_receive_accountmessage(self._accountmessage_value) |
| 4246 | return True |
| 4247 | |
| 4248 | return False |
nothing calls this directly
no test coverage detected