* Attaches handlers for the given transport. * * @param {Transport} transport * @private
(transport: Transport)
| 245 | * @private |
| 246 | */ |
| 247 | private setTransport(transport: Transport) { |
| 248 | const onError = this.onError.bind(this); |
| 249 | const onReady = () => this.flush(); |
| 250 | const onPacket = this.onPacket.bind(this); |
| 251 | const onDrain = this.onDrain.bind(this); |
| 252 | const onClose = this.onClose.bind(this, "transport close"); |
| 253 | |
| 254 | this.transport = transport; |
| 255 | this.transport.once("error", onError); |
| 256 | this.transport.on("ready", onReady); |
| 257 | this.transport.on("packet", onPacket); |
| 258 | this.transport.on("drain", onDrain); |
| 259 | this.transport.once("close", onClose); |
| 260 | |
| 261 | this.cleanupFn.push(function () { |
| 262 | transport.removeListener("error", onError); |
| 263 | transport.removeListener("ready", onReady); |
| 264 | transport.removeListener("packet", onPacket); |
| 265 | transport.removeListener("drain", onDrain); |
| 266 | transport.removeListener("close", onClose); |
| 267 | }); |
| 268 | } |
| 269 | |
| 270 | /** |
| 271 | * Upon transport "drain" event |
no test coverage detected