Luca Barbato

I guess the latter has to report an error somehow, maybe adding a `{fail:component}` modifier so both behaviors are supported?

I think it is enough, thank you :)

My, supposedly tiny, application should do something like this: 1. listen on an address for a single connection 2. once it receives the connection listen for as many connections as...

The idea was to prevent further producers to connect, probably there is a cleaner solution now :)

With the suggested change I got: ``` error[E0282]: type annotations needed --> src/main.rs:259:28 | 259 | let (tx, rx) = oneshot::channel(); | -------- ^^^^^^^^^^^^^^^^ cannot infer type for `T` |...

It seems working with few more `.map(...).map_err()`, sadly I couldn't polish a proper full example yet :) thank you a lot!