{"_id":"writable-async-iterable-stream","_rev":"401865","name":"writable-async-iterable-stream","description":"An async stream which can be iterated over using a for-await-of loop.","dist-tags":{"latest":"5.1.0"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"time":{"modified":"2021-08-04T04:33:43.000Z","created":"2018-11-18T17:57:53.162Z","5.1.0":"2019-01-17T19:58:26.361Z","5.0.0":"2019-01-17T07:52:59.809Z","4.0.1":"2018-12-09T17:47:16.141Z","4.0.0":"2018-12-08T23:33:25.590Z","3.0.2":"2018-12-06T00:26:27.576Z","3.0.1":"2018-12-05T23:22:56.521Z","3.0.0":"2018-12-05T23:00:53.027Z","2.1.1":"2018-12-04T20:55:37.694Z","2.1.0":"2018-12-04T18:06:25.953Z","2.0.2":"2018-12-03T22:08:35.923Z","2.0.1":"2018-12-02T13:31:28.412Z","2.0.0":"2018-12-02T13:18:00.203Z","1.2.0":"2018-11-20T08:13:26.763Z","1.1.1":"2018-11-19T23:33:15.248Z","1.1.0":"2018-11-19T00:58:08.111Z","1.0.9":"2018-11-18T18:02:50.495Z","1.0.8":"2018-11-18T17:57:53.162Z"},"users":{},"author":{"name":"Jonathan Gros-Dubois"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"versions":{"5.1.0":{"name":"writable-async-iterable-stream","version":"5.1.0","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^4.0.0"},"gitHead":"d02d472b0dfd9137dc3272fdf419f64071a52a6c","_id":"writable-async-iterable-stream@5.1.0","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"273ca8891ff3e94838fd1fc5fcf45f25713dd3c0","size":4546,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-5.1.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-5.1.0.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_5.1.0_1547755106219_0.37744903633421045"},"_hasShrinkwrap":false,"publish_time":1547755106361,"_cnpm_publish_time":1547755106361},"5.0.0":{"name":"writable-async-iterable-stream","version":"5.0.0","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^4.0.0"},"gitHead":"a7b02968fa72370dc43d872e9d0fdbc8381f9500","_id":"writable-async-iterable-stream@5.0.0","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"b3cfef7e656fcf3279ac9ee8fba487eaa7b84202","size":4456,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-5.0.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-5.0.0.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_5.0.0_1547711579719_0.35407788150074615"},"_hasShrinkwrap":false,"publish_time":1547711579809,"_cnpm_publish_time":1547711579809},"4.0.1":{"name":"writable-async-iterable-stream","version":"4.0.1","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^3.0.1"},"gitHead":"9fb3a4945da31ce0b1285a7db1e22e7c394e4807","_id":"writable-async-iterable-stream@4.0.1","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"392e023f189eed95c4ab1e704454ca55e12d5ccc","size":4309,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-4.0.1.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-4.0.1.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_4.0.1_1544377636014_0.15618651648709303"},"_hasShrinkwrap":false,"publish_time":1544377636141,"_cnpm_publish_time":1544377636141},"4.0.0":{"name":"writable-async-iterable-stream","version":"4.0.0","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^3.0.0"},"gitHead":"9dc19ee79314de07fbb3c18d48f46a2123f0146b","_id":"writable-async-iterable-stream@4.0.0","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"ccf6146b5d8a0072d145109705a522a2f360287c","size":4306,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-4.0.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-4.0.0.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_4.0.0_1544312005439_0.1507518311087297"},"_hasShrinkwrap":false,"publish_time":1544312005590,"_cnpm_publish_time":1544312005590},"3.0.2":{"name":"writable-async-iterable-stream","version":"3.0.2","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^2.0.3"},"gitHead":"e1ab611b606b0505e3a4c7edf2c3ecdb4da91887","_id":"writable-async-iterable-stream@3.0.2","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"36c74a6a3c0f465db5d1bf0495c2d47d3dfbb914","size":3581,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-3.0.2.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-3.0.2.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_3.0.2_1544055987441_0.5945688499779018"},"_hasShrinkwrap":false,"publish_time":1544055987576,"_cnpm_publish_time":1544055987576},"3.0.1":{"name":"writable-async-iterable-stream","version":"3.0.1","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^2.0.1"},"gitHead":"fd76b46033a54f94f1fff9a57da50cbe2ee61c76","_id":"writable-async-iterable-stream@3.0.1","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"a81e90863673e922335036e67f81e9538eb04a93","size":3592,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-3.0.1.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-3.0.1.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_3.0.1_1544052176397_0.8382589769942215"},"_hasShrinkwrap":false,"publish_time":1544052176521,"_cnpm_publish_time":1544052176521},"3.0.0":{"name":"writable-async-iterable-stream","version":"3.0.0","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^2.0.0"},"gitHead":"8f771377309f49887fdcbf96a3f4c438aa9140fe","_id":"writable-async-iterable-stream@3.0.0","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"e4f86a9551108d75faff29e79dd1597649aa7233","size":3422,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-3.0.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-3.0.0.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_3.0.0_1544050852931_0.4053997078303031"},"_hasShrinkwrap":false,"publish_time":1544050853027,"_cnpm_publish_time":1544050853027},"2.1.1":{"name":"writable-async-iterable-stream","version":"2.1.1","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^1.2.1"},"gitHead":"617102aa46984b193ddad7684d2ca6e7b69f9f78","_id":"writable-async-iterable-stream@2.1.1","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"9c0cfea241781b278a8a1f8d94d718a6a225b319","size":3424,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-2.1.1.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-2.1.1.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_2.1.1_1543956937580_0.1864402411506163"},"_hasShrinkwrap":false,"publish_time":1543956937694,"_cnpm_publish_time":1543956937694},"2.1.0":{"name":"writable-async-iterable-stream","version":"2.1.0","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^1.2.1"},"gitHead":"ddf394adfada0906fbc17c6003b6a645870af604","_id":"writable-async-iterable-stream@2.1.0","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"3f4aefa8311fe8a7f3c2558a947439b67a5f0beb","size":3402,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-2.1.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-2.1.0.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_2.1.0_1543946785816_0.45739847981261517"},"_hasShrinkwrap":false,"publish_time":1543946785953,"_cnpm_publish_time":1543946785953},"2.0.2":{"name":"writable-async-iterable-stream","version":"2.0.2","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^1.2.1"},"gitHead":"24d58497db57179e200969d7fc55c15cc397603c","_id":"writable-async-iterable-stream@2.0.2","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"0ab7e69b153b4605333ee42e8ff92e9e340ae025","size":3522,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-2.0.2.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-2.0.2.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_2.0.2_1543874915795_0.3476848663307477"},"_hasShrinkwrap":false,"publish_time":1543874915923,"_cnpm_publish_time":1543874915923},"2.0.1":{"name":"writable-async-iterable-stream","version":"2.0.1","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^1.2.1"},"gitHead":"9254c4a68e2674fdeaff96ec49cc56cb73623e27","_id":"writable-async-iterable-stream@2.0.1","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"09986982b85b19846f09d30b0a850913b897fce6","size":3508,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-2.0.1.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-2.0.1.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_2.0.1_1543757488329_0.09247442730089062"},"_hasShrinkwrap":false,"publish_time":1543757488412,"_cnpm_publish_time":1543757488412},"2.0.0":{"name":"writable-async-iterable-stream","version":"2.0.0","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^1.2.1"},"gitHead":"051a9ac52980ac17b4e71696391ce0672aeadbb5","_id":"writable-async-iterable-stream@2.0.0","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"a0f2056532243f251db52856e9544ce64f00ad66","size":3562,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-2.0.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-2.0.0.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_2.0.0_1543756679998_0.04097803223685381"},"_hasShrinkwrap":false,"publish_time":1543756680203,"_cnpm_publish_time":1543756680203},"1.2.0":{"name":"writable-async-iterable-stream","version":"1.2.0","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^1.2.0"},"gitHead":"4e56719c6b25d7fdbdcd0e7de2f01e817414d6d2","_id":"writable-async-iterable-stream@1.2.0","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"b2f490812aa6e32789238d93cf24d7aa865f0099","size":3009,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-1.2.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-1.2.0.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_1.2.0_1542701606660_0.1262336709377032"},"_hasShrinkwrap":false,"publish_time":1542701606763,"_cnpm_publish_time":1542701606763},"1.1.1":{"name":"writable-async-iterable-stream","version":"1.1.1","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^1.1.0"},"gitHead":"e4bcdc4f6aab1d1acc91dcd0d10f16127df8559d","_id":"writable-async-iterable-stream@1.1.1","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"91b1abc701cda85ae54b1e69b00d4cb73efa7a9f","size":3010,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-1.1.1.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-1.1.1.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_1.1.1_1542670395040_0.35093718269055274"},"_hasShrinkwrap":false,"publish_time":1542670395248,"_cnpm_publish_time":1542670395248},"1.1.0":{"name":"writable-async-iterable-stream","version":"1.1.0","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^1.0.3"},"gitHead":"791f387f90fe2d6efa405ffcc19a77be3ff870d8","_id":"writable-async-iterable-stream@1.1.0","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"690fbc38653446053c3a6adc4c809c8431b6f8a0","size":2914,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-1.1.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-1.1.0.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_1.1.0_1542589087975_0.05799751135697173"},"_hasShrinkwrap":false,"publish_time":1542589088111,"_cnpm_publish_time":1542589088111},"1.0.9":{"name":"writable-async-iterable-stream","version":"1.0.9","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^1.0.1"},"gitHead":"f4bbb6f897699190adea02bcd64e935fecb6327d","_id":"writable-async-iterable-stream@1.0.9","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"57b0c7183a93580570efb878732275a673801706","size":2691,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-1.0.9.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-1.0.9.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_1.0.9_1542564170423_0.975407466045455"},"_hasShrinkwrap":false,"publish_time":1542564170495,"_cnpm_publish_time":1542564170495},"1.0.8":{"name":"writable-async-iterable-stream","version":"1.0.8","description":"An async stream which can be iterated over using a for-await-of loop.","main":"index.js","scripts":{"test":"./node_modules/mocha/bin/_mocha --reporter spec --timeout 10000 --slow 10000"},"repository":{"type":"git","url":"git+ssh://git@github.com/SocketCluster/writable-async-iterable-stream.git"},"keywords":["async","generator","stream","data","for-await-of"],"author":{"name":"Jonathan Gros-Dubois"},"license":"MIT","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","devDependencies":{"mocha":"^5.2.0"},"dependencies":{"async-iterable-stream":"^1.0.1"},"gitHead":"3c3c863bf4b318ce0e19edca7e4899794314d272","_id":"writable-async-iterable-stream@1.0.8","_npmVersion":"5.6.0","_nodeVersion":"10.0.0","_npmUser":{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"},"dist":{"shasum":"fb63ece654eb7b5a4aa3ce4163d836592fa10087","size":2695,"noattachment":false,"key":"/writable-async-iterable-stream/-/writable-async-iterable-stream-1.0.8.tgz","tarball":"http://registry.cnpm.dingdandao.com/writable-async-iterable-stream/download/writable-async-iterable-stream-1.0.8.tgz"},"maintainers":[{"name":"topcloudsystems","email":"grosjona@yahoo.com.au"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/writable-async-iterable-stream_1.0.8_1542563873020_0.5210300818028399"},"_hasShrinkwrap":false,"publish_time":1542563873162,"_cnpm_publish_time":1542563873162}},"readme":"# writable-async-iterable-stream\nAn async stream which can be iterated over using a for-await-of loop and which can be written to.\n\nThe `WritableAsyncIterableStream` class extends the `AsyncIterableStream` class.  \nSee https://github.com/SocketCluster/async-iterable-stream\n\n## Installation\n\n```\nnpm install writable-async-iterable-stream\n```\n\n## Usage\n\n### Consume a stream and write to it asynchronously:\n\n```js\nlet iterableStream = new WritableAsyncIterableStream();\n\nasync function consumeAsyncIterable(asyncIterable) {\n  // Consume iterable data asynchronously.\n  for await (let packet of asyncIterable) {\n    console.log('Packet:', packet);\n  }\n}\nconsumeAsyncIterable(iterableStream);\n\nsetInterval(() => {\n  // Write data to the stream asynchronously,\n  iterableStream.write(`Timestamp: ${Date.now()}`);\n}, 100);\n```\n\n### Consume a stream using a while loop:\n\n```js\nlet iterableStream = new WritableAsyncIterableStream();\n\nasync function consumeAsyncIterable(asyncIterable) {\n  // Consume iterable data asynchronously.\n  // Works in older environments.\n  let asyncIterator = stream.createAsyncIterator();\n  while (true) {\n    let packet = await asyncIterator.next();\n    if (packet.done) break;\n    console.log('Packet:', packet.value);\n  }\n}\nconsumeAsyncIterable(iterableStream);\n\nsetInterval(() => {\n  // Write data to the stream asynchronously,\n  iterableStream.write(`Timestamp: ${Date.now()}`);\n}, 100);\n```\n\n### Consume a filtered stream using an async generator:\n\n```js\nlet iterableStream = new WritableAsyncIterableStream();\n\n// Creates an async generator which only produces packets which are allowed by the\n// specified filterFunction.\nasync function* createFilteredStreamGenerator(fullStream, filterFunction) {\n  for await (let packet of fullStream) {\n    if (filterFunction(packet)) {\n      yield packet;\n    }\n  }\n};\n\nasync function consumeAsyncIterable(asyncIterable) {\n  // Consume iterable data asynchronously.\n  for await (let packet of asyncIterable) {\n    console.log('Packet:', packet);\n  }\n}\n\n// The filter function will only include strings which end with the number 5.\nfunction filterFn(data) {\n  return /5$/.test(data);\n}\nlet filteredStreamGenerator = createFilteredStreamGenerator(iterableStream, filterFn);\n\nconsumeAsyncIterable(filteredStreamGenerator);\n\nsetInterval(() => {\n  // Write data to the stream asynchronously,\n  iterableStream.write(`Timestamp: ${Date.now()}`);\n}, 100);\n```\n\n### Consume only the next data object which will be written to the stream:\n\n```js\nlet iterableStream = new WritableAsyncIterableStream();\n\n(async () => {\n  let data = await iterableStream.once();\n  console.log(data);\n})();\n\nsetInterval(() => {\n  // Write data to the stream asynchronously,\n  iterableStream.write(`Timestamp: ${Date.now()}`);\n}, 100);\n```\n\nSee `test/` directory for additional examples.\n","_attachments":{},"homepage":"https://github.com/SocketCluster/writable-async-iterable-stream#readme","bugs":{"url":"https://github.com/SocketCluster/writable-async-iterable-stream/issues"},"license":"MIT"}