mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-07-24 19:25:55 +00:00
Fix legacy substream fallback not working (#6826)
* Fix legacy substream fallback not working * Make it nicer
This commit is contained in:
@@ -600,15 +600,10 @@ impl ProtocolsHandler for NotifsHandler {
|
|||||||
message
|
message
|
||||||
} => {
|
} => {
|
||||||
for (handler, _) in &mut self.out_handlers {
|
for (handler, _) in &mut self.out_handlers {
|
||||||
if handler.protocol_name() != &protocol_name[..] {
|
if handler.protocol_name() == &protocol_name[..] && handler.is_open() {
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
if handler.is_open() {
|
|
||||||
handler.send_or_discard(message);
|
handler.send_or_discard(message);
|
||||||
|
continue 'poll_notifs_sink;
|
||||||
}
|
}
|
||||||
|
|
||||||
continue 'poll_notifs_sink;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
self.legacy.inject_event(LegacyProtoHandlerIn::SendCustomMessage {
|
self.legacy.inject_event(LegacyProtoHandlerIn::SendCustomMessage {
|
||||||
|
|||||||
Reference in New Issue
Block a user