* proto receive message handler * @this {!Client} * @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)
| 6937 | * @returns {!boolean} Success flag |
| 6938 | */ |
| 6939 | onReceive (type, buffer, offset, size) { |
| 6940 | switch (type) { |
| 6941 | case OrderMessageModel.fbeType: { |
| 6942 | // Deserialize the value from the FBE stream |
| 6943 | this._OrderMessageReceiverModel.attachBuffer(buffer, offset) |
| 6944 | console.assert(this._OrderMessageReceiverModel.verify(), 'proto.OrderMessage validation failed!') |
| 6945 | let deserialized = this._OrderMessageReceiverModel.deserialize(this._OrderMessageReceiverValue) |
| 6946 | console.assert((deserialized.size > 0), 'proto.OrderMessage deserialization failed!') |
| 6947 | |
| 6948 | // Log the value |
| 6949 | if (this.logging) { |
| 6950 | this.onReceiveLog(this._OrderMessageReceiverValue.toString()) |
| 6951 | } |
| 6952 | |
| 6953 | // Call receive handler with deserialized value |
| 6954 | this.onReceive_OrderMessage(this._OrderMessageReceiverValue) |
| 6955 | return true |
| 6956 | } |
| 6957 | case BalanceMessageModel.fbeType: { |
| 6958 | // Deserialize the value from the FBE stream |
| 6959 | this._BalanceMessageReceiverModel.attachBuffer(buffer, offset) |
| 6960 | console.assert(this._BalanceMessageReceiverModel.verify(), 'proto.BalanceMessage validation failed!') |
| 6961 | let deserialized = this._BalanceMessageReceiverModel.deserialize(this._BalanceMessageReceiverValue) |
| 6962 | console.assert((deserialized.size > 0), 'proto.BalanceMessage deserialization failed!') |
| 6963 | |
| 6964 | // Log the value |
| 6965 | if (this.logging) { |
| 6966 | this.onReceiveLog(this._BalanceMessageReceiverValue.toString()) |
| 6967 | } |
| 6968 | |
| 6969 | // Call receive handler with deserialized value |
| 6970 | this.onReceive_BalanceMessage(this._BalanceMessageReceiverValue) |
| 6971 | return true |
| 6972 | } |
| 6973 | case AccountMessageModel.fbeType: { |
| 6974 | // Deserialize the value from the FBE stream |
| 6975 | this._AccountMessageReceiverModel.attachBuffer(buffer, offset) |
| 6976 | console.assert(this._AccountMessageReceiverModel.verify(), 'proto.AccountMessage validation failed!') |
| 6977 | let deserialized = this._AccountMessageReceiverModel.deserialize(this._AccountMessageReceiverValue) |
| 6978 | console.assert((deserialized.size > 0), 'proto.AccountMessage deserialization failed!') |
| 6979 | |
| 6980 | // Log the value |
| 6981 | if (this.logging) { |
| 6982 | this.onReceiveLog(this._AccountMessageReceiverValue.toString()) |
| 6983 | } |
| 6984 | |
| 6985 | // Call receive handler with deserialized value |
| 6986 | this.onReceive_AccountMessage(this._AccountMessageReceiverValue) |
| 6987 | return true |
| 6988 | } |
| 6989 | default: break |
| 6990 | } |
| 6991 | return false |
| 6992 | } |
| 6993 | |
| 6994 | /** |
| 6995 | * Setup receive log message handler |
nothing calls this directly
no test coverage detected