()
| 60 | this._writer = encoderStream.writable.getWriter(); |
| 61 | |
| 62 | const read = () => { |
| 63 | reader |
| 64 | .read() |
| 65 | .then(({ done, value }) => { |
| 66 | if (done) { |
| 67 | debug(class="st">"session is closed"); |
| 68 | return; |
| 69 | } |
| 70 | debug(class="st">"received chunk: %o", value); |
| 71 | this.onPacket(value); |
| 72 | read(); |
| 73 | }) |
| 74 | .catch((err) => { |
| 75 | debug(class="st">"an error occurred while reading: %s", err); |
| 76 | }); |
| 77 | }; |
| 78 | |
| 79 | read(); |
| 80 |
no test coverage detected