RxPY

RxPY copied to clipboard

Hi, Thanks for this useful library. I'm trying to go through a tutorial which lists the `switch_map()` operator. I can see this operator in the code (as the alias of...

paulkorir

**Describe the bug** Maybe I'm not seeing something, but I believe the example https://github.com/ReactiveX/RxPY/blob/master/examples/parallel/timer.py is broken for RxPY 4.0.4. Instead of printing the output it prints nothing, which is due...

cheind

Python 3.12 deprecates timezone non aware utcfromtimestamp() and utcnow()

2

**Describe the bug** There are some deprecation warnings with Python 3.12. **To Reproduce** Run tests with Python 3.12 **Expected behavior** Tests should run clean. For example: ``` /builddir/build/BUILD/reactivex-4.0.4/reactivex/internal/basic.py:17: DeprecationWarning: datetime.datetime.utcnow()...

traylenator

**Describe the bug** *buffer_with_time_or_count* loses data when the timer is the trigger and the `on_next` releases the GIL. Related issue: https://github.com/ReactiveX/RxPY/issues/702, but this issue can get solved by using a...

laurens-teirlynck

[BUG] buffer_with_time_or_count lost some data

1

**Describe the bug** A clear and concise description of what the bug is. buffer_with_time_or_count lost some data **To Reproduce** Steps to reproduce the behavior: ```python result = [] ( reactivex.range(100_000)...

fanck0605

We expect them to be equal, but they are not ```python result = [] ( reactivex.range(100_000) .pipe( operators.buffer_with_time_or_count(timespan=0.001, count=10_000), ) .subscribe(on_next=lambda x: result.extend(x)) ) print(f"len(result) = {len(result)}") assert result ==...

fanck0605

**Describe the bug** Downloading the 4.0.4 release from GitHub: ``` steven@conjecture:/tmp/tmp.d811GMff6W% wget -q https://github.com/ReactiveX/RxPY/archive/refs/tags/v4.0.4.tar.gz steven@conjecture:/tmp/tmp.d811GMff6W% tar zxf v4.0.4.tar.gz steven@conjecture:/tmp/tmp.d811GMff6W% cd RxPY-4.0.4 steven@conjecture:/tmp/tmp.d811GMff6W/RxPY-4.0.4% grep version pyproject.toml version = "0.0.0" # NOTE:...

s-t-e-v-e-n-k

Fix timer second subscription

1

Closes #697 - Add test for multiple subscriptions - Fix `duetime` being overridden and set to a value which will (likely) be in the past for future subscriptions

matiboy

reactivex.timer emits immediately on second subscription

1

An observable created by `reactivex.timer(1,5)` will emit immediately when a second observer subscribes instead of waiting the "1" second specified as argument. This only happens when an interval value is...

matiboy

unexpected behaviour regarding item count

2

**Describe the bug** How is is plausible in my example below that with the marked section commented out the numbers that are printed before the section always sum to 2000...

jonathan-dev