-
Notifications
You must be signed in to change notification settings - Fork 356
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Connectable observable sends events multiple times #591
Comments
Hello @igordertigor, How is done the branch/merge at p1 and p3? your issue may come from that part of the pipeline |
Hi @MainRo,
Once the whole pipeline is set up, I call |
I'm using rxpy for a realtime audio processing tool. The tool receives two event streams, one that contains audio chunks and one that contains small text like annotation snippets. The flow looks similar to this:
Here, the
p<x>
nodes are processing nodes (implemented in numpy/pytorch) and therec
node is a recorder, that writes its input to disk and otherwise passes it on unchanged. I'm using the.publish()
call to support the branching that comes after therec
node.When I open the audio file written by the
rec
node, every chunk has been written 3 times, which implies that therec
node received every chunk 3 times. Is this intended behaviour? How can I avoid this? I'm worried that downstream nodes (p1-p5) might receive multiple repetitions of the same chunk as well and therefore might not operate as intended. However, the pipeline as a whole seems to work correctly.I tried a number of variations:
.publish()
call: Events in the first pipeline get stuck right beforep3
.p4
never receives any events.rec
node that drops events if they have the same md5 sum as the previous event (either using a combination ofscan
andfilter
or afilter
with a class). This makes the audio file look ok, but the overall pipeline becomes prohibitively slow and is essentially broken..publish()
call to a later stage: The results are essentially the same as 1.Thank you for your help.
The text was updated successfully, but these errors were encountered: