(self, type, buffer, offset, size)
| 4372 | pass |
| 4373 | |
| 4374 | def on_receive(self, type, buffer, offset, size): |
| 4375 | |
| 4376 | if type == OrderMessageFinalModel.TYPE: |
| 4377 | # Deserialize the value from the FBE stream |
| 4378 | self._ordermessage_model.attach_buffer(buffer, offset) |
| 4379 | assert self._ordermessage_model.verify(), "protoex.OrderMessage validation failed!" |
| 4380 | (_, deserialized) = self._ordermessage_model.deserialize(self._ordermessage_value) |
| 4381 | assert (deserialized > 0), "protoex.OrderMessage deserialization failed!" |
| 4382 | |
| 4383 | # Log the value |
| 4384 | if self.logging: |
| 4385 | message = str(self._ordermessage_value) |
| 4386 | self.on_receive_log(message) |
| 4387 | |
| 4388 | # Call receive handler with deserialized value |
| 4389 | self.on_receive_ordermessage(self._ordermessage_value) |
| 4390 | return True |
| 4391 | |
| 4392 | if type == BalanceMessageFinalModel.TYPE: |
| 4393 | # Deserialize the value from the FBE stream |
| 4394 | self._balancemessage_model.attach_buffer(buffer, offset) |
| 4395 | assert self._balancemessage_model.verify(), "protoex.BalanceMessage validation failed!" |
| 4396 | (_, deserialized) = self._balancemessage_model.deserialize(self._balancemessage_value) |
| 4397 | assert (deserialized > 0), "protoex.BalanceMessage deserialization failed!" |
| 4398 | |
| 4399 | # Log the value |
| 4400 | if self.logging: |
| 4401 | message = str(self._balancemessage_value) |
| 4402 | self.on_receive_log(message) |
| 4403 | |
| 4404 | # Call receive handler with deserialized value |
| 4405 | self.on_receive_balancemessage(self._balancemessage_value) |
| 4406 | return True |
| 4407 | |
| 4408 | if type == AccountMessageFinalModel.TYPE: |
| 4409 | # Deserialize the value from the FBE stream |
| 4410 | self._accountmessage_model.attach_buffer(buffer, offset) |
| 4411 | assert self._accountmessage_model.verify(), "protoex.AccountMessage validation failed!" |
| 4412 | (_, deserialized) = self._accountmessage_model.deserialize(self._accountmessage_value) |
| 4413 | assert (deserialized > 0), "protoex.AccountMessage deserialization failed!" |
| 4414 | |
| 4415 | # Log the value |
| 4416 | if self.logging: |
| 4417 | message = str(self._accountmessage_value) |
| 4418 | self.on_receive_log(message) |
| 4419 | |
| 4420 | # Call receive handler with deserialized value |
| 4421 | self.on_receive_accountmessage(self._accountmessage_value) |
| 4422 | return True |
| 4423 | |
| 4424 | if (self.proto_receiver is not None) and self.proto_receiver.on_receive(type, buffer, offset, size): |
| 4425 | return True |
| 4426 | |
| 4427 | return False |
nothing calls this directly
no test coverage detected