Vincent Michel

Results 75 comments of Vincent Michel

@ap-- Thanks! Also I just remembered the recipe is actually included in the package. By the way, I noticed two differences between the recipe from the repo and the one...

Here's a typical scenario related to this issue: During a file synchronization, an access to the local database fails with an `OperationalError`. This might happen in `set_clean_block` due to the...

> Of course we can also go full yolo, just build the wheel on ubuntu and consider it is "fine enough" ;-) No need to go yolo when when we...

@AGhost-7 Thanks for the report ! Interesting, but how would you expect `create_standard_streams` to behave in this case? Do you still need async access to stdout and stderr even though...

Hi @andersea ! > I have a few instances where I need to send the same items to multiple consumers. There's a related issue about this use case: #35 It's...

@graingert Right, thanks for the info! So before implementing the [rest of the task list](https://github.com/vxgmichel/aiostream/pull/60#issue-374271732), we'll first have to: - migrate to anyio v3 - drop curio support - solve...

Right, the [debounce](http://reactivex.io/documentation/operators/debounce.html) operator in ReactiveX! Here's my attempt at implementing it, can you confirm it works as you expect? ```python import asyncio from collections import deque from aiostream import...

> I'm relieved to see your approach still uses `anext` and `asyncio.wait`. I was half wondering if you were going to do something like a `merge(source, delay(just(TIMEOUT_SENTINEL)))` and then iterate...

> But for more general use cases, to me the following feel natural: [...] Good points! I agree with most of it, except for delaying the last item. I don't...

> What is the current state of library? I'm maintaining it (e.g supporting new python releases) but I'm not actively developing it. Do you need the `debounce` operator? I guess...