(message: Uint8Array)
| 693 | } |
| 694 | |
| 695 | private async _publish(message: Uint8Array) { |
| 696 | this.room.broadcastExcept(message, this.socket); |
| 697 | |
| 698 | await getRedis().publish( |
| 699 | this.room.name, |
| 700 | Buffer.concat([getSelfPublisherIdBytes(), message]), |
| 701 | ); |
| 702 | } |
| 703 | |
| 704 | destroySocket() { |
| 705 | // Terminate socket |
no test coverage detected