RxPY
RxPY copied to clipboard
ReactiveX
ReactiveX for Python
- take - timestamp - average Additionally 1. Typed `run`'s return to T_out not Any 2. Removed `average`'s never hit check for count == 0 (take_last operator already raises) and...
**Describe the bug** The error is produced if one tries to pickle reactive classes (e.g. Subject). TypeError: cannot pickle '_thread.RLock' object Maybe it makes sense to add something like: def...
This PR fixes `starmap_indexed` not actually passing the index to the function This could be considered a breaking change, although I suspect the impact would be minor. Anyone currently using...
Not certain this is right, please correct :) `Disposable` nor `DisposableBase` are not documented so it wasn't clear what you could do with them.
WIP branch for refactoring RxPY to use `curry_flip` from the Expression library. This will remove a lot of boilerplate code and make the operator code more readable (no nested functions).
Hi, I want to pass data from a background thread into the main thread. I have the following code, but it seems that `CurrentThreadScheduler()` is not doing what I expect....
Hello, I'm currently encountering an issue with RxPY where I'm trying to execute multiple tasks concurrently using ThreadPoolScheduler, but they seem to be executing sequentially instead. My goal is to...
**Describe the bug** When using e.g. `operators.retry(3)` the operator will stop the emission after 3 repeats even though no error had been raised. **To Reproduce** I feel that the below...
Fixes Python 3.12 DeprecationWarning's https://github.com/ReactiveX/RxPY/issues/705
I was doing something with F# and ReactiveX, and noticed that because of F#'s `|>` operator, their pipelining syntax is a lot cleaner and more readable: ```fsharp let reqWithTimeout =...
