RxPY

RxPY copied to clipboard

concat_map implementation or equivalent?

2

Coming from RxJS it was really convenient having the concatMap operator to have a pipeline of dynamic observables that wait for the previous to complete. I noticed that RxPY does...

iyz91

__eq__ implementation for Notification class

1

The __eq__ magic method for the Notification class seems to be implemented as a comparison of the two sides of the equality being casted to string. This can lead to...

azhou95

Can't emmit items to observer in infinite loop

2

Hey everyone, I am building a small app that listens to WebSocket stream and parses the received events. I tried to mock the basic functionality in the code snippet: ```...

yoavweber

Connectable observable sends events multiple times

2

I'm using rxpy for a realtime audio processing tool. The tool receives two event streams, one that contains audio chunks and one that contains small text like annotation snippets. The...

igordertigor

Memory usage increases with subject and threadpool scheduler

3

Hi, I'm using rxpy for an event-driven application and after some stress tests I noticed a strange behaviour on memory usage. I've created a simple script to reproduce the issue....

damianoct

Adding Initial Value to Subject using start_with doesn't work for subscribe with AsyncIOScheduler

1

Hi I am trying to combine Subject with start_with operator as I want the each observer to get the initial image using start_with and the subsequence update via Subject on_next....

lamkenn

Exceptions get silently dropped when using from_iterable()

1

Observables created with rx.just() and rx.from_iterable() handle exceptions differently on subscription. - rx.just() raises the exception to the caller - rx.from_iterable() drops it. ``` import rx import rx.operators as op...

vgklein

Convert async iterator to Obervable

5

Does RxPY provide a facility for converting async iterators into Observables? For example, if I have: ``` async foo(): for x in range(5): result = await get_data_from_somewhere(x) yield result ```...

samfrances

When using `from_iterable` with a generator the generator might not be closed

8

Example code: ```python from typing import Iterator from contextlib import contextmanager from rx import from_iterable from rx.operators import take @contextmanager def my_context(): print('enter context') yield print('release context') def my_generator() ->...

Carsten-Leue

"subscribe_on" and Observable.create "scheduler" parameter inconsistent

1

I'm a little confused about subscribe_on and the 'scheduler' parameter of Observable.create: ## Example ```python import rx import rx.scheduler import rx.operators as op import time import threading scheduler = rx.scheduler.ThreadPoolScheduler(max_workers=5)...

freelancer1845