pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-06-13 05:51:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

End multiplexer stream once one of its inputs end. (#2380)

Browse Source 
* End multiplexer stream once one of its inputs end.

Also add test, that we don't panic once a stream is exhausted.

* Don't fuse already fused stream.
This commit is contained in:
Robert Klotzner
2021-02-04 12:31:36 +01:00
committed by GitHub
parent 62d18c708c
commit cfcde3d3b0
2 changed files with 49 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
polkadot/node/network/bridge/src/lib.rs
+1 -1
View File
@@ -169,7 +169,7 @@ where
let action = {
let subsystem_next = ctx.recv().fuse();
let mut net_event_next = event_stream.next().fuse();
let mut req_res_event_next = bridge.request_multiplexer.next().fuse();
let mut req_res_event_next = bridge.request_multiplexer.next();
futures::pin_mut!(subsystem_next);
futures::select! {