alanshaw
it-pushable
An iterable that you can push values into
About
An iterable that you can push values into.
Example
import { pushable } from 'it-pushable'
const source = pushable()
setTimeout(() => source.push('hello'), 100)
setTimeout(() => source.push('world'), 200)
setTimeout(() => source.end(), 300)
const start = Date.now()
for await (const value of source) {
console.log(`got "${value}" after ${Date.now() - start}ms`)
}
console.log(`done after ${Date.now() - start}ms`)
// Output:
// got "hello" after 105ms
// got "world" after 207ms
// done after 309msExample
import { pushableV } from 'it-pushable'
import all from 'it-all'
const source = pushableV()
source.push(1)
source.push(2)
source.push(3)
source.end()
console.info(await all(source))
// Output:
// [ [1, 2, 3] ]Table of contents
Install
$ npm i it-pushableBrowser <script> tag
Loading this module through a script tag will make it's exports available as ItPushable in the global namespace.
<script src="https://unpkg.com/it-pushable/dist/index.min.js"></script>Usage
import { pushable } from 'it-pushable'
const source = pushable()
setTimeout(() => source.push('hello'), 100)
setTimeout(() => source.push('world'), 200)
setTimeout(() => source.end(), 300)
const start = Date.now()
for await (const value of source) {
console.log(`got "${value}" after ${Date.now() - start}ms`)
}
console.log(`done after ${Date.now() - start}ms`)
/*
Output:
got "hello" after 105ms
got "world" after 207ms
done after 309ms
*/import { pushableV } from 'it-pushable'
import all from 'it-all'
const source = pushableV()
source.push(1)
source.push(2)
source.push(3)
source.end()
console.info(await all(source))
/*
Output:
[ [1, 2, 3] ]
*/Related
it-pipeUtility to "pipe" async iterables together
API Docs
License
Licensed under either of
- Apache 2.0, (LICENSE-APACHE / http://www.apache.org/licenses/LICENSE-2.0)
- MIT (LICENSE-MIT / http://opensource.org/licenses/MIT)
Contribution
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.