* proto receive message handler * @this {!FinalClient} * @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)
| 7614 | * @returns {!boolean} Success flag |
| 7615 | */ |
| 7616 | onReceive (type, buffer, offset, size) { |
| 7617 | switch (type) { |
| 7618 | case OrderMessageFinalModel.fbeType: { |
| 7619 | // Deserialize the value from the FBE stream |
| 7620 | this._OrderMessageReceiverModel.attachBuffer(buffer, offset) |
| 7621 | console.assert(this._OrderMessageReceiverModel.verify(), 'proto.OrderMessage validation failed!') |
| 7622 | let deserialized = this._OrderMessageReceiverModel.deserialize(this._OrderMessageReceiverValue) |
| 7623 | console.assert((deserialized.size > 0), 'proto.OrderMessage deserialization failed!') |
| 7624 | |
| 7625 | // Log the value |
| 7626 | if (this.logging) { |
| 7627 | this.onReceiveLog(this._OrderMessageReceiverValue.toString()) |
| 7628 | } |
| 7629 | |
| 7630 | // Call receive handler with deserialized value |
| 7631 | this.onReceive_OrderMessage(this._OrderMessageReceiverValue) |
| 7632 | return true |
| 7633 | } |
| 7634 | case BalanceMessageFinalModel.fbeType: { |
| 7635 | // Deserialize the value from the FBE stream |
| 7636 | this._BalanceMessageReceiverModel.attachBuffer(buffer, offset) |
| 7637 | console.assert(this._BalanceMessageReceiverModel.verify(), 'proto.BalanceMessage validation failed!') |
| 7638 | let deserialized = this._BalanceMessageReceiverModel.deserialize(this._BalanceMessageReceiverValue) |
| 7639 | console.assert((deserialized.size > 0), 'proto.BalanceMessage deserialization failed!') |
| 7640 | |
| 7641 | // Log the value |
| 7642 | if (this.logging) { |
| 7643 | this.onReceiveLog(this._BalanceMessageReceiverValue.toString()) |
| 7644 | } |
| 7645 | |
| 7646 | // Call receive handler with deserialized value |
| 7647 | this.onReceive_BalanceMessage(this._BalanceMessageReceiverValue) |
| 7648 | return true |
| 7649 | } |
| 7650 | case AccountMessageFinalModel.fbeType: { |
| 7651 | // Deserialize the value from the FBE stream |
| 7652 | this._AccountMessageReceiverModel.attachBuffer(buffer, offset) |
| 7653 | console.assert(this._AccountMessageReceiverModel.verify(), 'proto.AccountMessage validation failed!') |
| 7654 | let deserialized = this._AccountMessageReceiverModel.deserialize(this._AccountMessageReceiverValue) |
| 7655 | console.assert((deserialized.size > 0), 'proto.AccountMessage deserialization failed!') |
| 7656 | |
| 7657 | // Log the value |
| 7658 | if (this.logging) { |
| 7659 | this.onReceiveLog(this._AccountMessageReceiverValue.toString()) |
| 7660 | } |
| 7661 | |
| 7662 | // Call receive handler with deserialized value |
| 7663 | this.onReceive_AccountMessage(this._AccountMessageReceiverValue) |
| 7664 | return true |
| 7665 | } |
| 7666 | default: break |
| 7667 | } |
| 7668 | return false |
| 7669 | } |
| 7670 | |
| 7671 | /** |
| 7672 | * Setup receive log message handler |
nothing calls this directly
no test coverage detected