* protoex 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)
| 7181 | * @returns {!boolean} Success flag |
| 7182 | */ |
| 7183 | onReceive (type, buffer, offset, size) { |
| 7184 | switch (type) { |
| 7185 | case OrderMessageModel.fbeType: { |
| 7186 | // Deserialize the value from the FBE stream |
| 7187 | this._OrderMessageReceiverModel.attachBuffer(buffer, offset) |
| 7188 | console.assert(this._OrderMessageReceiverModel.verify(), 'protoex.OrderMessage validation failed!') |
| 7189 | let deserialized = this._OrderMessageReceiverModel.deserialize(this._OrderMessageReceiverValue) |
| 7190 | console.assert((deserialized.size > 0), 'protoex.OrderMessage deserialization failed!') |
| 7191 | |
| 7192 | // Log the value |
| 7193 | if (this.logging) { |
| 7194 | this.onReceiveLog(this._OrderMessageReceiverValue.toString()) |
| 7195 | } |
| 7196 | |
| 7197 | // Call receive handler with deserialized value |
| 7198 | this.onReceive_OrderMessage(this._OrderMessageReceiverValue) |
| 7199 | return true |
| 7200 | } |
| 7201 | case BalanceMessageModel.fbeType: { |
| 7202 | // Deserialize the value from the FBE stream |
| 7203 | this._BalanceMessageReceiverModel.attachBuffer(buffer, offset) |
| 7204 | console.assert(this._BalanceMessageReceiverModel.verify(), 'protoex.BalanceMessage validation failed!') |
| 7205 | let deserialized = this._BalanceMessageReceiverModel.deserialize(this._BalanceMessageReceiverValue) |
| 7206 | console.assert((deserialized.size > 0), 'protoex.BalanceMessage deserialization failed!') |
| 7207 | |
| 7208 | // Log the value |
| 7209 | if (this.logging) { |
| 7210 | this.onReceiveLog(this._BalanceMessageReceiverValue.toString()) |
| 7211 | } |
| 7212 | |
| 7213 | // Call receive handler with deserialized value |
| 7214 | this.onReceive_BalanceMessage(this._BalanceMessageReceiverValue) |
| 7215 | return true |
| 7216 | } |
| 7217 | case AccountMessageModel.fbeType: { |
| 7218 | // Deserialize the value from the FBE stream |
| 7219 | this._AccountMessageReceiverModel.attachBuffer(buffer, offset) |
| 7220 | console.assert(this._AccountMessageReceiverModel.verify(), 'protoex.AccountMessage validation failed!') |
| 7221 | let deserialized = this._AccountMessageReceiverModel.deserialize(this._AccountMessageReceiverValue) |
| 7222 | console.assert((deserialized.size > 0), 'protoex.AccountMessage deserialization failed!') |
| 7223 | |
| 7224 | // Log the value |
| 7225 | if (this.logging) { |
| 7226 | this.onReceiveLog(this._AccountMessageReceiverValue.toString()) |
| 7227 | } |
| 7228 | |
| 7229 | // Call receive handler with deserialized value |
| 7230 | this.onReceive_AccountMessage(this._AccountMessageReceiverValue) |
| 7231 | return true |
| 7232 | } |
| 7233 | default: break |
| 7234 | } |
| 7235 | |
| 7236 | // noinspection RedundantIfStatementJS |
| 7237 | if ((this.protoClient != null) && this.protoClient.onReceive(type, buffer, offset, size)) { |
| 7238 | return true |
| 7239 | } |
| 7240 |
nothing calls this directly
no test coverage detected