When pipe() is used and the destination is slow, what mechanism stops the source from overwhelming it, and what observable state does the source enter?
src.pipe(slow); // slow has a small highWaterMark
setImmediate(() => console.log(src.isPaused()));