* protoex 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)
| 6724 | * @returns {!boolean} Success flag |
| 6725 | */ |
| 6726 | onReceive (type, buffer, offset, size) { |
| 6727 | switch (type) { |
| 6728 | case OrderMessageModel.fbeType: { |
| 6729 | // Deserialize the value from the FBE stream |
| 6730 | this._OrderMessageModel.attachBuffer(buffer, offset) |
| 6731 | console.assert(this._OrderMessageModel.verify(), 'protoex.OrderMessage validation failed!') |
| 6732 | let deserialized = this._OrderMessageModel.deserialize(this._OrderMessageValue) |
| 6733 | console.assert((deserialized.size > 0), 'protoex.OrderMessage deserialization failed!') |
| 6734 | |
| 6735 | // Log the value |
| 6736 | if (this.logging) { |
| 6737 | this.onReceiveLog(this._OrderMessageValue.toString()) |
| 6738 | } |
| 6739 | |
| 6740 | // Call receive handler with deserialized value |
| 6741 | this.onReceive_OrderMessage(this._OrderMessageValue) |
| 6742 | return true |
| 6743 | } |
| 6744 | case BalanceMessageModel.fbeType: { |
| 6745 | // Deserialize the value from the FBE stream |
| 6746 | this._BalanceMessageModel.attachBuffer(buffer, offset) |
| 6747 | console.assert(this._BalanceMessageModel.verify(), 'protoex.BalanceMessage validation failed!') |
| 6748 | let deserialized = this._BalanceMessageModel.deserialize(this._BalanceMessageValue) |
| 6749 | console.assert((deserialized.size > 0), 'protoex.BalanceMessage deserialization failed!') |
| 6750 | |
| 6751 | // Log the value |
| 6752 | if (this.logging) { |
| 6753 | this.onReceiveLog(this._BalanceMessageValue.toString()) |
| 6754 | } |
| 6755 | |
| 6756 | // Call receive handler with deserialized value |
| 6757 | this.onReceive_BalanceMessage(this._BalanceMessageValue) |
| 6758 | return true |
| 6759 | } |
| 6760 | case AccountMessageModel.fbeType: { |
| 6761 | // Deserialize the value from the FBE stream |
| 6762 | this._AccountMessageModel.attachBuffer(buffer, offset) |
| 6763 | console.assert(this._AccountMessageModel.verify(), 'protoex.AccountMessage validation failed!') |
| 6764 | let deserialized = this._AccountMessageModel.deserialize(this._AccountMessageValue) |
| 6765 | console.assert((deserialized.size > 0), 'protoex.AccountMessage deserialization failed!') |
| 6766 | |
| 6767 | // Log the value |
| 6768 | if (this.logging) { |
| 6769 | this.onReceiveLog(this._AccountMessageValue.toString()) |
| 6770 | } |
| 6771 | |
| 6772 | // Call receive handler with deserialized value |
| 6773 | this.onReceive_AccountMessage(this._AccountMessageValue) |
| 6774 | return true |
| 6775 | } |
| 6776 | default: break |
| 6777 | } |
| 6778 | |
| 6779 | // noinspection RedundantIfStatementJS |
| 6780 | if ((this.protoReceiver != null) && this.protoReceiver.onReceive(type, buffer, offset, size)) { |
| 6781 | return true |
| 6782 | } |
| 6783 |
nothing calls this directly
no test coverage detected