Pull streams over window.postMessage
npm install pull-postmsg-stream


> Pull streams over window.postMessage
It provides the two parts of a through stream: a source stream and a sink stream that can be used together to stream data over window.postMessage.
``sh`
npm install pull-postmsg-stream
To use pull-postmsg-stream you need two window objects. One of the window objects _has_ the data, the other _wants_ the data. Under the hood, pull-postmsg-stream uses postmsg-rpc. If you're not familiar with it, it's a good idea to read up on how it works before continuing!
In the first window (the one that _has_ the data):
`js
const pull = require('pull-stream')
const PMS = require('pull-postmsg-stream')
pull(
pull.values([/ your data /]),
PMS.sink('read', {/ options passed to postmsg-rpc expose /})
)
`
In the second window (the one that _wants_ the data):
`js
const pull = require('pull-stream')
const PMS = require('pull-postmsg-stream')
pull(
PMS.source('read', {/ options passed to postmsg-rpc caller /}),
pull.collect(console.log) // Collects and logs out your data
)
`
1. Window that _has_ the data calls PMS.sink, which exposes a function called "read" & returns a sink streamPMS.source
2. Window that _wants_ the data calls , which creates a caller function for "read" & returns a source streampull(...)
3. In the window that _wants_ the data, the pipeline starts the flow of data from the PMS.source streamPMS.source
4. When data is requested from the stream, it calls the exposed "read" functionPMS.sink
5. This causes the stream in the window that _has_ the data to pull out of pull.values and return it all the way back to pull.collect in the window that _wants_ the data
See the example for complete code.
To build and run the example, run the following in your terminal:
`sh`
git clone https://github.com/tableflip/pull-postmsg-stream.git
cd pull-postmsg-stream
npm install
npm run example
Then open your browser at http://localhost:3000
Creates a new sink stream for exposing data to be pulled over postMessage.
* readFnName - the name of the function that postmsg-rpc will expose for a PMS.source stream to read fromoptions
* - options passed directly to postmsg-rpc expose, see docs hereoptions.post
* - function to call after read, see docs here
Note that if you're going to create multiple streams, you'll need to generate a new readFnName for each stream and somehow communicate that to your other window so that it can create a PMS.source that reads from the correct place.
Creates a new source stream for pulling data over postMessage.
* readFnName - the same name that was passed to PMS.sink, allowing the source to read from the sinkoptions
* - options passed directly to postmsg-rpc caller, see docs hereoptions.post` - function to call after read, see docs here
*
Feel free to dive in! Open an issue or submit PRs.
MIT © Alan Shaw