(
encodedPackets: Array<string | Buffer>,
opts: WriteOptions,
)
| 229 | } |
| 230 | |
| 231 | private writeToEngine( |
| 232 | encodedPackets: Array<string | Buffer>, |
| 233 | opts: WriteOptions, |
| 234 | ): void { |
| 235 | if (opts.volatile && !this.conn.transport.writable) { |
| 236 | debug( |
| 237 | "volatile packet is discarded since the transport is not currently writable", |
| 238 | ); |
| 239 | return; |
| 240 | } |
| 241 | const packets = Array.isArray(encodedPackets) |
| 242 | ? encodedPackets |
| 243 | : [encodedPackets]; |
| 244 | for (const encodedPacket of packets) { |
| 245 | this.conn.write(encodedPacket, opts); |
| 246 | } |
| 247 | } |
| 248 | |
| 249 | /** |
| 250 | * Called with incoming transport data. |
no test coverage detected