RxPY
RxPY copied to clipboard
ReactiveX for Python
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...