pub fn event_stream(&self, name: &'static str) -> impl Stream<Item = Event> {
		let (tx, rx) = out_events::channel(name);
		let _ = self.to_worker.unbounded_send(ServiceToWorkerMsg::EventStream(tx));
		rx
	}
/// Returns a stream containing the events that happen on the network.
///
/// If this method is called multiple times, the events are duplicated.
///
/// The stream never ends (unless the `NetworkWorker` gets shut down).
///
/// The name passed is used to identify the channel in the Prometheus metrics. Note that the
/// parameter is a `&'static str`, and not a `String`, in order to avoid accidentally having
/// an unbounded set of Prometheus metrics, which would be quite bad in terms of memory
Returns a stream containing the events that happen on the network.
If this method is called multiple times, the events are duplicated.

The stream never ends (unless the `NetworkWorker` gets shut down).

The name passed is used to identify the channel in the Prometheus metrics. Note that the
parameter is a `&'static str`, and not a `String`, in order to avoid accidentally having
an unbounded set of Prometheus metrics, which would be quite bad in terms of memory
Returns a stream containing the events that happen on the network . If this method is called multiple times the events are duplicated . The stream never ends ( unless the ` NetworkWorker ` gets shut down ) . The name passed is used to identify the channel in the Prometheus metrics . Note that the parameter is a ` & ' static str ` and not a ` String ` in order to avoid accidentally having an unbounded set of Prometheus metrics which would be quite bad in terms of memory
pub fn event_stream(&self, name: &'static str) -> impl Stream<Item = Event> {
		let (tx, rx) = out_events::channel(name);
		let _ = self.to_worker.unbounded_send(ServiceToWorkerMsg::EventStream(tx));
		rx
	}
pub fn event_stream ( & self , name : & ' static str ) -> impl Stream < Item = Event > { let ( tx , rx ) = out_events :: channel ( name ) ; let _ = self . to_worker . unbounded_send ( ServiceToWorkerMsg :: EventStream ( tx ) ) ; rx }
Returns a stream containing the events that happen on the network.
Returns a stream containing the events that happen on the network .
&self
name
&'static str
&self
name
&'static str