diff --git a/src/MessageSource/MessageSource.ts b/src/MessageSource/MessageSource.ts index 0f780f2..b77ea4b 100644 --- a/src/MessageSource/MessageSource.ts +++ b/src/MessageSource/MessageSource.ts @@ -26,6 +26,7 @@ export class MessageSource extends EventEmitter implements MessageSource { protected onEventArrive(packet: KHEventPacket): void { if ((packet as KHEventPacket).sn === this.sn + 1) { this.sn += 1 + if (this.sn >= 65535) this.sn = 0; this.emit('message', cloneDeep(packet.d)) this.eventProcess(packet) this.buffer.sort((a, b) => a.sn - b.sn)