aioreactive

aioreactive copied to clipboard

**The complete code is extended , but this is a summary.** > This exception does not represent a real problem because my application finishes executing all the functions correctly, and...

bueltan

rx.delay frequently destroys tasks

1

Hi, i'm unsure if this is the intended behaviour, but rx.delay causes asyncio to frequently throw the following error. if i'm not mistaken, rx.delay(x: seconds) is supposed to be an...

shawnkoh

Implementing reduce

2

Hello, Is there a reduce operator or not yet? If not, let me know and I will try to implement it.

francipvb

I'm trying to adapt the concat operator to implement the catch_exception op, but just noticed that the concat fails with an async iterable. I'm using the following observable: ``` async...

tr11

Hi. I tried to run Autocomplete's sample. However, it did not work well with the following error. (I fixed the import part before running.) ``` WebSocket opened was never yielded...

pistatium

documentation for creating observable streams

1

I've got a functions: ```python def get_producer(): tool = Tool() async def start(listener): def on_event(event): listener(event) tool.on_scan_result = on_event tool.start_scan() await tool.transport.drain() async def stop(): tool.stop_scanning() await tool.transport.drain() return {...

graingert

```python import asyncio from aioreactive.core import AsyncObservable, run async def generator(): # Also fails with sync generators for i in range(10): if i > 2: print("Let's raise") raise ValueError(i) #...

dmzkrsk

Just trying to wrap my head about these concepts.

dmzkrsk

Is there an operator to connect an Observable to an Observer, and if not, which one would you prefer?

3

Hi Dag, I think the pipe syntax for chaining operators is really cool, and am missing something similar to complete the chain. That is, I find myself writing code like...

ZmeiGorynych

Are there any more radical interface changes coming such as those of 27 days ago?

2

Dag, the wave of commits 27 days ago aligned the API more with RxPY and introduced quite a number of breaking API changes (subscribe instead of start, etc). Could you...

ZmeiGorynych