* Dispatch incoming event to socket listeners. * * @param {Array} event - event that will get emitted * @private
(event: Event)
| 818 | * @private |
| 819 | */ |
| 820 | private dispatch(event: Event): void { |
| 821 | debug("dispatching an event %j", event); |
| 822 | this.run(event, (err) => { |
| 823 | process.nextTick(() => { |
| 824 | if (err) { |
| 825 | return this._onerror(err); |
| 826 | } |
| 827 | if (this.connected) { |
| 828 | super.emitUntyped.apply(this, event); |
| 829 | } else { |
| 830 | debug("ignore packet received after disconnection"); |
| 831 | } |
| 832 | }); |
| 833 | }); |
| 834 | } |
| 835 | |
| 836 | /** |
| 837 | * Sets up socket middleware. |