* protoex 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)
| 7947 | * @returns {!boolean} Success flag |
| 7948 | */ |
| 7949 | onReceive (type, buffer, offset, size) { |
| 7950 | switch (type) { |
| 7951 | case OrderMessageFinalModel.fbeType: { |
| 7952 | // Deserialize the value from the FBE stream |
| 7953 | this._OrderMessageReceiverModel.attachBuffer(buffer, offset) |
| 7954 | console.assert(this._OrderMessageReceiverModel.verify(), 'protoex.OrderMessage validation failed!') |
| 7955 | let deserialized = this._OrderMessageReceiverModel.deserialize(this._OrderMessageReceiverValue) |
| 7956 | console.assert((deserialized.size > 0), 'protoex.OrderMessage deserialization failed!') |
| 7957 | |
| 7958 | // Log the value |
| 7959 | if (this.logging) { |
| 7960 | this.onReceiveLog(this._OrderMessageReceiverValue.toString()) |
| 7961 | } |
| 7962 | |
| 7963 | // Call receive handler with deserialized value |
| 7964 | this.onReceive_OrderMessage(this._OrderMessageReceiverValue) |
| 7965 | return true |
| 7966 | } |
| 7967 | case BalanceMessageFinalModel.fbeType: { |
| 7968 | // Deserialize the value from the FBE stream |
| 7969 | this._BalanceMessageReceiverModel.attachBuffer(buffer, offset) |
| 7970 | console.assert(this._BalanceMessageReceiverModel.verify(), 'protoex.BalanceMessage validation failed!') |
| 7971 | let deserialized = this._BalanceMessageReceiverModel.deserialize(this._BalanceMessageReceiverValue) |
| 7972 | console.assert((deserialized.size > 0), 'protoex.BalanceMessage deserialization failed!') |
| 7973 | |
| 7974 | // Log the value |
| 7975 | if (this.logging) { |
| 7976 | this.onReceiveLog(this._BalanceMessageReceiverValue.toString()) |
| 7977 | } |
| 7978 | |
| 7979 | // Call receive handler with deserialized value |
| 7980 | this.onReceive_BalanceMessage(this._BalanceMessageReceiverValue) |
| 7981 | return true |
| 7982 | } |
| 7983 | case AccountMessageFinalModel.fbeType: { |
| 7984 | // Deserialize the value from the FBE stream |
| 7985 | this._AccountMessageReceiverModel.attachBuffer(buffer, offset) |
| 7986 | console.assert(this._AccountMessageReceiverModel.verify(), 'protoex.AccountMessage validation failed!') |
| 7987 | let deserialized = this._AccountMessageReceiverModel.deserialize(this._AccountMessageReceiverValue) |
| 7988 | console.assert((deserialized.size > 0), 'protoex.AccountMessage deserialization failed!') |
| 7989 | |
| 7990 | // Log the value |
| 7991 | if (this.logging) { |
| 7992 | this.onReceiveLog(this._AccountMessageReceiverValue.toString()) |
| 7993 | } |
| 7994 | |
| 7995 | // Call receive handler with deserialized value |
| 7996 | this.onReceive_AccountMessage(this._AccountMessageReceiverValue) |
| 7997 | return true |
| 7998 | } |
| 7999 | default: break |
| 8000 | } |
| 8001 | |
| 8002 | // noinspection RedundantIfStatementJS |
| 8003 | if ((this.protoClient != null) && this.protoClient.onReceive(type, buffer, offset, size)) { |
| 8004 | return true |
| 8005 | } |
| 8006 |
nothing calls this directly
no test coverage detected