* Called upon event packet. * * @param {Packet} packet - packet object * @private
(packet: Packet)
| 650 | * @private |
| 651 | */ |
| 652 | private onevent(packet: Packet): void { |
| 653 | const args = packet.data || []; |
| 654 | debug("emitting event %j", args); |
| 655 | |
| 656 | if (null != packet.id) { |
| 657 | debug("attaching ack callback to event"); |
| 658 | args.push(this.ack(packet.id)); |
| 659 | } |
| 660 | |
| 661 | if (this._anyListeners && this._anyListeners.length) { |
| 662 | const listeners = this._anyListeners.slice(); |
| 663 | for (const listener of listeners) { |
| 664 | listener.apply(this, args); |
| 665 | } |
| 666 | } |
| 667 | this.dispatch(args); |
| 668 | } |
| 669 | |
| 670 | /** |
| 671 | * Produces an ack callback to emit with an event. |