* Dispatch incoming event to socket listeners. * * @param {Array} event - event that will get emitted * @private
(event: Event)
| 911 | * @private |
| 912 | */ |
| 913 | private dispatch(event: Event): void { |
| 914 | debug("dispatching an event %j", event); |
| 915 | this.run(event, (err) => { |
| 916 | process.nextTick(() => { |
| 917 | if (err) { |
| 918 | return this._onerror(err); |
| 919 | } |
| 920 | if (this.connected) { |
| 921 | super.emitUntyped.apply(this, event); |
| 922 | } else { |
| 923 | debug("ignore packet received after disconnection"); |
| 924 | } |
| 925 | }); |
| 926 | }); |
| 927 | } |
| 928 | |
| 929 | /** |
| 930 | * Sets up socket middleware. |