{"_id":"@zkochan/zen-push","_rev":"940508","name":"@zkochan/zen-push","description":"An Observable push stream","dist-tags":{"latest":"1.0.0"},"maintainers":[{"name":"zkochan","email":"zoltan.kochan+github@gmail.com"}],"time":{"modified":"2021-09-23T02:06:52.000Z","created":"2019-01-01T02:32:07.155Z","1.0.0":"2019-01-01T02:32:07.155Z"},"users":{},"repository":{"type":"git","url":"git+https://github.com/zkochan/zen-push.git"},"versions":{"1.0.0":{"name":"@zkochan/zen-push","version":"1.0.0","repository":{"type":"git","url":"git+https://github.com/zkochan/zen-push.git"},"description":"An Observable push stream","homepage":"https://github.com/zkochan/zen-push","license":"MIT","dependencies":{"@types/zen-observable":"^0.8.0","zen-observable":"^0.8.6"},"engines":{"node":">=6"},"scripts":{"test":"node test"},"gitHead":"b23319d2a68e21a74efb2bd0ae4e736724e4a30b","bugs":{"url":"https://github.com/zkochan/zen-push/issues"},"_id":"@zkochan/zen-push@1.0.0","_npmVersion":"6.5.0","_nodeVersion":"10.12.0","_npmUser":{"name":"zkochan","email":"z@kochan.io"},"dist":{"shasum":"255f009a22bfb6fa8f480dbd144c7ee19f479246","size":2257,"noattachment":false,"key":"/@zkochan/zen-push/-/@zkochan/zen-push-1.0.0.tgz","tarball":"http://registry.cnpm.dingdandao.com/@zkochan/zen-push/download/@zkochan/zen-push-1.0.0.tgz"},"maintainers":[{"name":"zkochan","email":"zoltan.kochan+github@gmail.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/zen-push_1.0.0_1546309927020_0.9782282423143067"},"_hasShrinkwrap":false,"publish_time":1546309927155,"_cnpm_publish_time":1546309927155}},"readme":"# @zkochan/zen-push\n\nA push stream observable class. *(Sometimes called a Subject in Rx-speak.)*\n\n## Install\n\n```sh\nnpm install @zkochan/zen-push\n```\n\n## Usage\n\n```js\nimport PushStream from '@zkochan/zen-push';\n\nlet pushStream = new PushStream();\npushStream.observable.subscribe(value => console.log(`Hello ${value}!`));\npushStream.next('World'); // 'Hello World!'\n```\n\n## API\n\n### new PushStream ( )\n\n```js\nlet pushStream = new PushStream();\n```\n\nCreates a new PushStream object.\n\n### pushStream.observable\n\n```js\npushStream.observable.subscribe(value => console.log(`Hello ${value}!`));\n```\n\nThe instance of [Observable](https://github.com/tc39/proposal-observable) used to listen to elements in the push stream.\n\n### pushStream.next ( value )\n\n```js\npushStream.next('World');\n```\n\nSends the next stream value to all observers.\n\n### pushStream.error ( error )\n\n```js\npushStream.error(new Error('The planet as been destroyed'));\n```\n\nSends an error to all observers. Calling this method terminates the stream.\n\n### pushStream.complete ( )\n\n```js\npushStream.complete();\n```\n\nSends a signal to all observers that the stream is finished. Calling this method terminates the stream.\n\n## License\n\nMIT\n","_attachments":{},"homepage":"https://github.com/zkochan/zen-push","bugs":{"url":"https://github.com/zkochan/zen-push/issues"},"license":"MIT"}