You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I'm attempting to use BroadcastFutReceiver as a stream combinator to get a Cloneable stream that I can share across threads. I have tried something similar to the following:
fncloneable<I,E,S>(stream:S) -> BroadcastFutReceiver<I>whereI:Clone,S:Stream<Item = I,Error = E>,{let(send, recv) = broadcast_fut_queue(1);
send.send_all(stream);// cannot coerce type E to type SendError<E>
recv
}
The issue I'm having is I'm not sure how to coerce my generic stream error type implementing T: std::error::Error into a multiqueue::SendError<T> as SendError is not public.
The text was updated successfully, but these errors were encountered:
I'm attempting to use
BroadcastFutReceiver
as a stream combinator to get aClone
able stream that I can share across threads. I have tried something similar to the following:The issue I'm having is I'm not sure how to coerce my generic stream error type implementing
T: std::error::Error
into amultiqueue::SendError<T>
asSendError
is not public.The text was updated successfully, but these errors were encountered: