| 463 | } |
| 464 | |
| 465 | private _hookTransport( |
| 466 | sid: SessionId, |
| 467 | transport: Transport, |
| 468 | lockType: "read" | "write", |
| 469 | senderId: NodeId, |
| 470 | ) { |
| 471 | if (lockType === "read") { |
| 472 | this._remoteTransports.set(sid, transport); |
| 473 | } |
| 474 | |
| 475 | transport.on("packet", async (packet: Packet) => |
| 476 | this._onPacket(sid, senderId, packet), |
| 477 | ); |
| 478 | transport.once("error", () => |
| 479 | this._onClose(sid, senderId, "transport error"), |
| 480 | ); |
| 481 | transport.once("close", () => |
| 482 | this._onClose(sid, senderId, "transport close"), |
| 483 | ); |
| 484 | } |
| 485 | |
| 486 | private _tryUpgrade( |
| 487 | transport: Transport, |