Paul Colomiets

What do you have in mind? Is it clean shutdown of the application, or is it just closing single bound socket? Can you show me the error message (is it...

Just convert the result on of the future: ``` tokio::run(srv_cons.map(|_| ()).map_err(|_| ())); ``` The idea is that `.select()` returns a tuple: the result of the one future and a wrapper...

Oh, by the way, do you use `tokio::run` which is blocking in asynchronous context (tokio loop that named `rt` in your code). This is a very bad idea. You should...

> The idea was to prevent further producers to connect, probably there is a cleaner solution now :) Sure. If you map "incoming" stream to a future, it waits for...

Oops, sorry, the following should work: ``` let (tx, rx) = oneshot::channel::(); ``` This means use `()` type for the channel. You can also apply annotation in `.map(...)` but it...

It's not postgres crash (postgres errors are often printed when we shutdown edgedb temporarily). It's the absense of systemd user daemon. You should be able to do something like this:...

Great! That said, we still may want to make github action work in a subdirectory, so keep the issue open.

No this is not intentional. 1. What is your platform? 2. Are you sure that you don't use other library that captures signals (maybe in some dependency)? 3. Do you...

I'm not sure that `sigtimedwait` exists on OS X. Contributions are welcome!

Well, sigpending in a loop with sleep might work. Another question is whether to unblock signals as part of `wait()` function call as this might be racy but would make...