RxPY icon indicating copy to clipboard operation
RxPY copied to clipboard

ReactiveX for Python

Results 59 RxPY issues
Sort by recently updated
recently updated
newest added

Update the used actions and the Python versions in the GitHub Actions CI workflows.

**Describe the bug** `AsyncIOScheduler.now` returns a datetime in 1970. **To Reproduce** ```bash python -c ' import asyncio from reactivex.scheduler.eventloop.asyncioscheduler import AsyncIOScheduler async def print_now(): print("Current time:", AsyncIOScheduler(asyncio.get_running_loop()).now) asyncio.run(print_now()) ' ```...

Python 3.14 will remove "asyncio.get_event_loop" https://docs.python.org/dev/whatsnew/3.14.html#id6 Replace "ayscio.get_event_loop

- Add ability to specify a scheduler for `Observable.run()` - Add type annotation for return type

This PR fixes the `subscribe_on` operator that actually doesn't forward the scheduler to the source. This is noticeable when one wants to implement an obsersvable by using a subscribe function:...

Hi everyone! I noticed a lot of Pull Requests, particularly concerning new features and tests. I'd like to help improve the test coverage using [CodeBeaver](https://www.codebeaver.ai), an AI agent that I...

see https://github.com/yaml/pyyaml/issues/724 for the origin of the error. We can remove this once pyyaml 7.0 is released.

Hi, I found that operators like ```python take_until_with_time(datetime) ``` depends on ```python scheduler.schedule_absolute(duetime) ``` to trigger, which then was implemented as ```python scheduler.schedule_relative(duetime - self.now) ``` For normal schedulers which...

**Is your feature request related to a problem? Please describe.** We're missing a basic capability - concat_map / concat_all. We're also missing alternatives that would allow it to be easily...