We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
SinkExt::send_all
TryStream
I have a Sink<MyMsg, Error=MyError> and I'd like to send_all it a stream, Stream<Item=Result<MyMsg, MyError>>.
Sink<MyMsg, Error=MyError>
send_all
Stream<Item=Result<MyMsg, MyError>>
StreamExt::forward almost works for me, but I need to keep using the Sink after.
StreamExt::forward
Sink
Perhaps a SinkExt::try_send_all with where St: TryStream<Ok = Item, Error = Error>? I can send a PR if you guys are open to it.
SinkExt::try_send_all
where St: TryStream<Ok = Item, Error = Error>
The text was updated successfully, but these errors were encountered:
Agreed-- TryStream seems sensible to support here.
Sorry, something went wrong.
Successfully merging a pull request may close this issue.
I have a
Sink<MyMsg, Error=MyError>
and I'd like tosend_all
it a stream,Stream<Item=Result<MyMsg, MyError>>
.StreamExt::forward
almost works for me, but I need to keep using theSink
after.Perhaps a
SinkExt::try_send_all
withwhere St: TryStream<Ok = Item, Error = Error>
? I can send a PR if you guys are open to it.The text was updated successfully, but these errors were encountered: