How to convert an event emitter to a Stream

[mspoulsen]

Yesterday I posted an issue regarding @most/create: #241

It was closed because we all thought we had a solution. But I don't think we do. So I have taken the liberty to create similar but slightly different issue. My question is:

How do I turn event emitters into a Stream? 😮

Event emitters come in many flavors. It could be a socket.io connection or like the example below, an animation library (this example is from popmotion):

tween().start(n => console.log(n))

Promises will not work, since a Promise only returns one value and I need to be able to push values to the Stream as they arrive.

most/create

create from the @most/create package would work. This function makes it nice and simple to push values to a stream, making it easy to write adapters for almost anything:

const stream$ = create(
    add => {
      tween(tweenProps).start((n: number) => add(n))
    })

However, @most/create does not seem to be compatible with @most/core? The type Stream have changed in @most/core.

Are there any plans to update the @most/create package?
Or can this be done using operators (that I am missing) in @most/core ?

Thanks in advance!

[davidchase]

@mspoulsen welcome back😛I don’t know if this https://github.com/mostjs-community/from-event/blob/master/README.md supports the new mostjs core but there you have it support event emitters.

Again I think it’s pretty simple to extract the source/sink pattern and create your own operators that you can submit to the community etc

[mspoulsen]

I have created my own adapters using the pattern from most from-event and it works like a charm. Thanks for your help! 👍 🙂

[davidchase]

Sweet glad to help

[davidchase]

looks like this is also good to close 👍

[gblok]

how emit/receive multiple arguments?
mostjs-community/from-event#10