Unverified Commit 5cfc9771 authored by Pierre Krieger's avatar Pierre Krieger Committed by GitHub
Browse files

Companion PR to channel names (#995)

* Companion PR to channel names

* Err... fix missing event stream name

* Update Substrate
parent 89328103
Pipeline #87777 passed with stages
in 32 minutes and 32 seconds
This diff is collapsed.
...@@ -225,7 +225,7 @@ pub fn start<C, Api, SP>( ...@@ -225,7 +225,7 @@ pub fn start<C, Api, SP>(
{ {
const SERVICE_TO_WORKER_BUF: usize = 256; const SERVICE_TO_WORKER_BUF: usize = 256;
let mut event_stream = service.event_stream(); let mut event_stream = service.event_stream("polkadot-network");
service.register_notifications_protocol(POLKADOT_ENGINE_ID, POLKADOT_PROTOCOL_NAME); service.register_notifications_protocol(POLKADOT_ENGINE_ID, POLKADOT_PROTOCOL_NAME);
let (mut worker_sender, worker_receiver) = mpsc::channel(SERVICE_TO_WORKER_BUF); let (mut worker_sender, worker_receiver) = mpsc::channel(SERVICE_TO_WORKER_BUF);
......
...@@ -502,7 +502,7 @@ pub fn new_full<Runtime, Dispatch, Extrinsic>( ...@@ -502,7 +502,7 @@ pub fn new_full<Runtime, Dispatch, Extrinsic>(
if authority_discovery_enabled { if authority_discovery_enabled {
let network = service.network(); let network = service.network();
let network_event_stream = network.event_stream(); let network_event_stream = network.event_stream("authority-discovery");
let dht_event_stream = network_event_stream.filter_map(|e| async move { match e { let dht_event_stream = network_event_stream.filter_map(|e| async move { match e {
Event::Dht(e) => Some(e), Event::Dht(e) => Some(e),
_ => None, _ => None,
......
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