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.