Based on this excellent SO answer I can get multiple tasks working in parallel in RxPy, my problem is how do you wait for them to all complete? I know using threading I can do .join() but there doe...

I need to create an Observable stream which emits the result of a async coroutine at regular intervals. intervalRead is a function which returns an Observable, and takes as parameters the interva...

I am hoping to make vals in the last line be more clear. import rx from rx import operators as op light_stream = rx.range(1, 10).pipe( op.with_latest_from(irradiance_stream), op.map(lambda vals...

I've got two event streams. One is from an inductance loop, the other is an IP camera. Cars will drive over the loop and then hit the camera. I want to combine them if the events are within N milli...

I have implemented a web service using Falcon. This service stores a state machine (pytransitions) that is passed to service's resources in the constructor. The service is runs with gunicorn. The ...

TL;DR I'm looking for help to implement the marble diagram below. The intention is to sort the non-sorted values to the extent possible without waiting time between scan executions. I'm not asking...

Say I have a long running python function that looks something like this? import random import time from rx import Observable def intns(x): y = random.randint(5,10) print(y) print('begin') tim...

(Note: The background for this problem is pretty verbose, but there's an SSCCE at the bottom that can be skipped to) Background I'm trying to develop a Python-based CLI to interact with a web ser...

I'm trying to get my head around the rxpy library for functional reactive programming (FRP) and I've already hit a roadblock. I'm writing a small program that expects data to be streamed in via sta...

I'm using Reactive Extensions' combine_latest to perform an action whenever any inputs tick. The problem is if multiple inputs tick at the same time then combine_latest fires multiple times after e...

I'm trying to get my head around scheduling in reactive extensions for python. I would like to use subscribe_on to process multiple observables in parallel. This works fine if the observable is cre...

I am trying to integrate ReactiveX into my GUI using RxPY. This is a general ReactiveX question. Say I have a visualization that depends on multiple Observable streams using combine_latest(stream1...