Integrating Streams with Callback Interface

I'm working with a callback interface (third party lib) that looks something like this:

onParsedToken: (callback: (token: Token) => void) => void;
write: (value: string) => void

onParsedToken: (callback: (token: Token) => void) => void;
write: (value: string) => void

I have a Stream "A" of string values that need to be fed to the

write()

write()

method, and I would like to push tokens received in the

onParsedToken

onParsedToken

callback to Stream "B".

I'd like to return a single stream that when "subscribed to" starts pulling values from Stream A, pushing them into Stream B - Stream B's emissions would be emitted in the "top level" Stream.

I'm not too sure how to achieve this

Effect Community•2y ago

peachneo

Integrating Streams with Callback Interface

I'm working with a callback interface (third party lib) that looks something like this:

onParsedToken: (callback: (token: Token) => void) => void;
write: (value: string) => void

onParsedToken: (callback: (token: Token) => void) => void;
write: (value: string) => void

I have a Stream "A" of string values that need to be fed to the

write()

write()

method, and I would like to push tokens received in the

onParsedToken

onParsedToken

Integrating Streams with Callback Interface

Similar Threads

Integrating Streams with Callback Interface

Similar Threads

Similar Threads

Similar Threads