* proto receive message handler * @this {!Receiver} * @param {!number} type Message type * @param {!Uint8Array} buffer Buffer to send * @param {!number} offset Buffer offset * @param {!number} size Buffer size * @returns {!boolean} Success flag
(type, buffer, offset, size)
| 6533 | * @returns {!boolean} Success flag |
| 6534 | */ |
| 6535 | onReceive (type, buffer, offset, size) { |
| 6536 | switch (type) { |
| 6537 | case OrderMessageModel.fbeType: { |
| 6538 | // Deserialize the value from the FBE stream |
| 6539 | this._OrderMessageModel.attachBuffer(buffer, offset) |
| 6540 | console.assert(this._OrderMessageModel.verify(), 'proto.OrderMessage validation failed!') |
| 6541 | let deserialized = this._OrderMessageModel.deserialize(this._OrderMessageValue) |
| 6542 | console.assert((deserialized.size > 0), 'proto.OrderMessage deserialization failed!') |
| 6543 | |
| 6544 | // Log the value |
| 6545 | if (this.logging) { |
| 6546 | this.onReceiveLog(this._OrderMessageValue.toString()) |
| 6547 | } |
| 6548 | |
| 6549 | // Call receive handler with deserialized value |
| 6550 | this.onReceive_OrderMessage(this._OrderMessageValue) |
| 6551 | return true |
| 6552 | } |
| 6553 | case BalanceMessageModel.fbeType: { |
| 6554 | // Deserialize the value from the FBE stream |
| 6555 | this._BalanceMessageModel.attachBuffer(buffer, offset) |
| 6556 | console.assert(this._BalanceMessageModel.verify(), 'proto.BalanceMessage validation failed!') |
| 6557 | let deserialized = this._BalanceMessageModel.deserialize(this._BalanceMessageValue) |
| 6558 | console.assert((deserialized.size > 0), 'proto.BalanceMessage deserialization failed!') |
| 6559 | |
| 6560 | // Log the value |
| 6561 | if (this.logging) { |
| 6562 | this.onReceiveLog(this._BalanceMessageValue.toString()) |
| 6563 | } |
| 6564 | |
| 6565 | // Call receive handler with deserialized value |
| 6566 | this.onReceive_BalanceMessage(this._BalanceMessageValue) |
| 6567 | return true |
| 6568 | } |
| 6569 | case AccountMessageModel.fbeType: { |
| 6570 | // Deserialize the value from the FBE stream |
| 6571 | this._AccountMessageModel.attachBuffer(buffer, offset) |
| 6572 | console.assert(this._AccountMessageModel.verify(), 'proto.AccountMessage validation failed!') |
| 6573 | let deserialized = this._AccountMessageModel.deserialize(this._AccountMessageValue) |
| 6574 | console.assert((deserialized.size > 0), 'proto.AccountMessage deserialization failed!') |
| 6575 | |
| 6576 | // Log the value |
| 6577 | if (this.logging) { |
| 6578 | this.onReceiveLog(this._AccountMessageValue.toString()) |
| 6579 | } |
| 6580 | |
| 6581 | // Call receive handler with deserialized value |
| 6582 | this.onReceive_AccountMessage(this._AccountMessageValue) |
| 6583 | return true |
| 6584 | } |
| 6585 | default: break |
| 6586 | } |
| 6587 | return false |
| 6588 | } |
| 6589 | |
| 6590 | /** |
| 6591 | * Setup receive log message handler |
nothing calls this directly
no test coverage detected