| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent 3bfc9f5 commit 86d1c0b
2 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -196,6 +196,7 @@ Transform.prototype._write = function(chunk, encoding, callback) { | |||
| 196 | 196 | wState.ended || // Backwards compat. | |
| 197 | 197 | length === rState.length || // Backwards compat. | |
| 198 | 198 | rState.length < rState.highWaterMark || | |
| 199 | + rState.highWaterMark === 0 || | ||
| 199 | 200 | rState.length === 0 | |
| 200 | 201 | ) { | |
| 201 | 202 | callback(); | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -0,0 +1,8 @@ | |||
| 1 | + 'use strict'; | ||
| 2 | + const common = require('../common'); | ||
| 3 | + const { PassThrough } = require('stream'); | ||
| 4 | + | ||
| 5 | + const pt = new PassThrough({ highWaterMark: 0 }); | ||
| 6 | + pt.on('drain', common.mustCall()); | ||
| 7 | + pt.write('hello'); | ||
| 8 | + pt.read(); | ||
| Back | FazBrowse Home | New Git URL |
0 commit comments