How to use the streaming-iterables.map 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-libp2p-tcp / test / listen-dial.spec.js View on Github 
listener = tcp.createListener((conn) => {
pipe(
conn,
map((x) => Buffer.from(x.toString() + '!')),
conn
)
})
await listener.listen(ma)listener = tcp.createListener((conn) => {
pipe(
conn,
map((x) => Buffer.from(x.toString() + '!')),
conn
)
})
await listener.listen(ma)async function createMarkedSet ({ pin, pinManager, refs, repo }) {
const pinsSource = map(({ cid }) => cid, pin.ls())
const pinInternalsSource = (async function * () {
const cids = await pinManager.getInternalBlocks()
yield * cids
})()
const mfsSource = (async function * () {
let mh
try {
mh = await repo.root.get(MFS_ROOT_KEY)
} catch (err) {
if (err.code === ERR_NOT_FOUND) {
log('No blocks in MFS')
return
}
throw errstreaming-iterables
A collection of utilities for async iterables. Designed to replace your streams.
