RxPY

RxPY copied to clipboard

Debounce operator does not ignore values, it queues them with delay

3

**Describe the bug** Debounce operator does not ignore values, it queues them with delay. **To Reproduce** ```python test = rx.interval(0.1).pipe( ops.debounce(1.5, scheduler=CurrentThreadScheduler()), ).subscribe(print) ``` Truth be told, I am using...

teodorkostov-es

Add switch_map operator and equivalent starred and indexed

5

This draws from the definition in rxjs and maintains parity with the map operator and its variants

giff-h

Switching scheduler to Main Thread

2

Hi there, just wondering how I can schedule work on specific threads, specifically the program's main thread? For example, I want to do certain map operations (here I use `do_action`)...

alek5k

Example noteboks are out of date

2

There are few places where examples in the notebooks are using wrong keyword parameters, eg Part VI buffer ``` -------------------------------------------------- TypeError Traceback (most recent call last) in () 4 opens...

immunochomik

Sample does not appear to emit `on_completed`

3

**Describe the bug** It appears to me that running `operators.sample` prevents the `on_completed` event from getting fired, while `on_error` works as expected. **To Reproduce** Steps to reproduce the behavior: 1....

markovejnovic

**Is your feature request related to a problem? Please describe.** No - this is about a convenience function. **Describe the solution you'd like** A function that allows for calling a...

Ivorforce

Unable to dispose observables subscribed on threadpool scheduler

1

**Describe the bug** This code ```py pool = ThreadPoolScheduler() run = rx.repeat_value(1).pipe( ops.subscribe_on(pool) ).subscribe() sleep(.5) run.dispose() ``` doesn't seems to be able to shutdown the `repeat_value` despite calling dispose. **To...

AstrickHarren

rx.timer works only with naive date object

1

The timer works only with naive datetime object. Because of it, I need to map my datetime object with offset to delta and then use it with the timer. I...

adsko

Change the number of operators in pipeline dynamically

2

Hello. I would like to know if it is possible to change the number of operators in the pipeline depending on the size of the array with the functions that...

AndrejAlpatov

Kivy scheduler is not in the library

2

I want to use Rx with [Kivy](https://kivy.org/), but it does not come with a scheduler for it. I know from past experience that to implement the Elm pattern I will...

mrakgr