(self, type, buffer, offset, size)
| 4198 | pass |
| 4199 | |
| 4200 | def on_receive(self, type, buffer, offset, size): |
| 4201 | |
| 4202 | if type == OrderMessageModel.TYPE: |
| 4203 | # Attach the FBE stream to the proxy model |
| 4204 | self._ordermessage_model.attach_buffer(buffer, offset) |
| 4205 | assert self._ordermessage_model.verify(), "protoex.OrderMessage validation failed!" |
| 4206 | |
| 4207 | fbe_begin = self._ordermessage_model.model.get_begin() |
| 4208 | if fbe_begin == 0: |
| 4209 | return False |
| 4210 | # Call proxy handler |
| 4211 | self.on_proxy_ordermessage(self._ordermessage_model, type, buffer, offset, size) |
| 4212 | self._ordermessage_model.model.get_end(fbe_begin) |
| 4213 | return True |
| 4214 | |
| 4215 | if type == BalanceMessageModel.TYPE: |
| 4216 | # Attach the FBE stream to the proxy model |
| 4217 | self._balancemessage_model.attach_buffer(buffer, offset) |
| 4218 | assert self._balancemessage_model.verify(), "protoex.BalanceMessage validation failed!" |
| 4219 | |
| 4220 | fbe_begin = self._balancemessage_model.model.get_begin() |
| 4221 | if fbe_begin == 0: |
| 4222 | return False |
| 4223 | # Call proxy handler |
| 4224 | self.on_proxy_balancemessage(self._balancemessage_model, type, buffer, offset, size) |
| 4225 | self._balancemessage_model.model.get_end(fbe_begin) |
| 4226 | return True |
| 4227 | |
| 4228 | if type == AccountMessageModel.TYPE: |
| 4229 | # Attach the FBE stream to the proxy model |
| 4230 | self._accountmessage_model.attach_buffer(buffer, offset) |
| 4231 | assert self._accountmessage_model.verify(), "protoex.AccountMessage validation failed!" |
| 4232 | |
| 4233 | fbe_begin = self._accountmessage_model.model.get_begin() |
| 4234 | if fbe_begin == 0: |
| 4235 | return False |
| 4236 | # Call proxy handler |
| 4237 | self.on_proxy_accountmessage(self._accountmessage_model, type, buffer, offset, size) |
| 4238 | self._accountmessage_model.model.get_end(fbe_begin) |
| 4239 | return True |
| 4240 | |
| 4241 | if (self.proto_proxy is not None) and self.proto_proxy.on_receive(type, buffer, offset, size): |
| 4242 | return True |
| 4243 | |
| 4244 | return False |
| 4245 | |
| 4246 | |
| 4247 | # Fast Binary Encoding protoex final sender |
no test coverage detected