1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26
// Copyright 2020 MaidSafe.net limited. // // This SAFE Network Software is licensed to you under The General Public License (GPL), version 3. // Unless required by applicable law or agreed to in writing, the SAFE Network Software distributed // under the GPL Licence is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY // KIND, either express or implied. Please review the Licences for the specific language governing // permissions and limitations relating to use of the SAFE Network Software. use crate::event::Event; use tokio::sync::mpsc; /// Stream of routing node events pub struct EventStream { events_rx: mpsc::UnboundedReceiver<Event>, } impl EventStream { pub(crate) fn new(events_rx: mpsc::UnboundedReceiver<Event>) -> Self { Self { events_rx } } /// Returns next event pub async fn next(&mut self) -> Option<Event> { self.events_rx.recv().await } }