How to use the streaming-iterables.tap function in streaming-iterables
To help you get started, we’ve selected a few streaming-iterables examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
libp2p / js-interfaces / src / stream-muxer / spawner.js View on Github 
const listener = new Muxer(async stream => {
expect(stream).to.exist // eslint-disable-line
check()
await pipe(
stream,
tap(chunk => check()),
consume
)
check()
pipe([], stream)
})streaming-iterables
A collection of utilities for async iterables. Designed to replace your streams.
