diff options
Diffstat (limited to 'futures/src/subscription.rs')
| -rw-r--r-- | futures/src/subscription.rs | 43 |
1 files changed, 14 insertions, 29 deletions
diff --git a/futures/src/subscription.rs b/futures/src/subscription.rs index 316fc44d..5ec39582 100644 --- a/futures/src/subscription.rs +++ b/futures/src/subscription.rs @@ -369,44 +369,29 @@ where /// // ... /// } /// -/// enum State { -/// Starting, -/// Ready(mpsc::Receiver<Input>), -/// } -/// /// fn some_worker() -> Subscription<Event> { /// struct SomeWorker; /// /// subscription::channel(std::any::TypeId::of::<SomeWorker>(), 100, |mut output| async move { -/// let mut state = State::Starting; -/// -/// loop { -/// match &mut state { -/// State::Starting => { -/// // Create channel -/// let (sender, receiver) = mpsc::channel(100); +/// // Create channel +/// let (sender, mut receiver) = mpsc::channel(100); /// -/// // Send the sender back to the application -/// output.send(Event::Ready(sender)).await; +/// // Send the sender back to the application +/// output.send(Event::Ready(sender)).await; /// -/// // We are ready to receive messages -/// state = State::Ready(receiver); -/// } -/// State::Ready(receiver) => { -/// use iced_futures::futures::StreamExt; +/// loop { +/// use iced_futures::futures::StreamExt; /// -/// // Read next input sent from `Application` -/// let input = receiver.select_next_some().await; +/// // Read next input sent from `Application` +/// let input = receiver.select_next_some().await; /// -/// match input { -/// Input::DoSomeWork => { -/// // Do some async work... +/// match input { +/// Input::DoSomeWork => { +/// // Do some async work... /// -/// // Finally, we can optionally produce a message to tell the -/// // `Application` the work is done -/// output.send(Event::WorkFinished).await; -/// } -/// } +/// // Finally, we can optionally produce a message to tell the +/// // `Application` the work is done +/// output.send(Event::WorkFinished).await; /// } /// } /// } |