Unverified Commit d8be456c authored by Ashley's avatar Ashley Committed by GitHub
Browse files

Update network/src/lib.rs



Co-Authored-By: Pierre Krieger's avatarPierre Krieger <pierre.krieger1708@gmail.com>
parent ec736727
Pipeline #71356 canceled with stage
in 4 seconds
...@@ -113,7 +113,7 @@ impl<T> av_store::ProvideGossipMessages for AvailabilityNetworkShim<T> ...@@ -113,7 +113,7 @@ impl<T> av_store::ProvideGossipMessages for AvailabilityNetworkShim<T>
where T: NetworkService where T: NetworkService
{ {
fn gossip_messages_for(&self, topic: Hash) fn gossip_messages_for(&self, topic: Hash)
-> Box<dyn Stream<Item = (Hash, Hash, ErasureChunk)> + Unpin + Send> -> Pin<Box<dyn Stream<Item = (Hash, Hash, ErasureChunk)> + Send>>
{ {
Box::new(self.0.gossip_messages_for(topic) Box::new(self.0.gossip_messages_for(topic)
.filter_map(|(msg, _)| async move { .filter_map(|(msg, _)| async move {
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment