* proto receive message handler * @this {!FinalReceiver} * @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)
| 7322 | * @returns {!boolean} Success flag |
| 7323 | */ |
| 7324 | onReceive (type, buffer, offset, size) { |
| 7325 | switch (type) { |
| 7326 | case OrderMessageFinalModel.fbeType: { |
| 7327 | // Deserialize the value from the FBE stream |
| 7328 | this._OrderMessageModel.attachBuffer(buffer, offset) |
| 7329 | console.assert(this._OrderMessageModel.verify(), 'proto.OrderMessage validation failed!') |
| 7330 | let deserialized = this._OrderMessageModel.deserialize(this._OrderMessageValue) |
| 7331 | console.assert((deserialized.size > 0), 'proto.OrderMessage deserialization failed!') |
| 7332 | |
| 7333 | // Log the value |
| 7334 | if (this.logging) { |
| 7335 | this.onReceiveLog(this._OrderMessageValue.toString()) |
| 7336 | } |
| 7337 | |
| 7338 | // Call receive handler with deserialized value |
| 7339 | this.onReceive_OrderMessage(this._OrderMessageValue) |
| 7340 | return true |
| 7341 | } |
| 7342 | case BalanceMessageFinalModel.fbeType: { |
| 7343 | // Deserialize the value from the FBE stream |
| 7344 | this._BalanceMessageModel.attachBuffer(buffer, offset) |
| 7345 | console.assert(this._BalanceMessageModel.verify(), 'proto.BalanceMessage validation failed!') |
| 7346 | let deserialized = this._BalanceMessageModel.deserialize(this._BalanceMessageValue) |
| 7347 | console.assert((deserialized.size > 0), 'proto.BalanceMessage deserialization failed!') |
| 7348 | |
| 7349 | // Log the value |
| 7350 | if (this.logging) { |
| 7351 | this.onReceiveLog(this._BalanceMessageValue.toString()) |
| 7352 | } |
| 7353 | |
| 7354 | // Call receive handler with deserialized value |
| 7355 | this.onReceive_BalanceMessage(this._BalanceMessageValue) |
| 7356 | return true |
| 7357 | } |
| 7358 | case AccountMessageFinalModel.fbeType: { |
| 7359 | // Deserialize the value from the FBE stream |
| 7360 | this._AccountMessageModel.attachBuffer(buffer, offset) |
| 7361 | console.assert(this._AccountMessageModel.verify(), 'proto.AccountMessage validation failed!') |
| 7362 | let deserialized = this._AccountMessageModel.deserialize(this._AccountMessageValue) |
| 7363 | console.assert((deserialized.size > 0), 'proto.AccountMessage deserialization failed!') |
| 7364 | |
| 7365 | // Log the value |
| 7366 | if (this.logging) { |
| 7367 | this.onReceiveLog(this._AccountMessageValue.toString()) |
| 7368 | } |
| 7369 | |
| 7370 | // Call receive handler with deserialized value |
| 7371 | this.onReceive_AccountMessage(this._AccountMessageValue) |
| 7372 | return true |
| 7373 | } |
| 7374 | default: break |
| 7375 | } |
| 7376 | return false |
| 7377 | } |
| 7378 | |
| 7379 | /** |
| 7380 | * Setup receive log message handler |
nothing calls this directly
no test coverage detected