me/iced
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Simplify subscription::channel example

Browse source
This commit is contained in:
Héctor Ramón Jiménez 2024-07-02 19:01:04 +02:00
parent 4687bf7f14
commit 2b19471d1c
No known key found for this signature in database
GPG key ID: 7CC46565708259A7
1 changed files with 14 additions and 29 deletions
Download patch file Download diff file Expand all files Collapse all files

19
futures/src/subscription.rs
View file

@ -369,30 +369,17 @@ where
/// // ... /// // ...
/// } /// }
/// ///
/// enum State {
/// Starting,
/// Ready(mpsc::Receiver<Input>),
/// }
///
/// fn some_worker() -> Subscription<Event> { /// fn some_worker() -> Subscription<Event> {
/// struct SomeWorker; /// struct SomeWorker;
/// ///
/// subscription::channel(std::any::TypeId::of::<SomeWorker>(), 100, |mut output| async move { /// 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 /// // Create channel
/// let (sender, receiver) = mpsc::channel(100); /// let (sender, mut receiver) = mpsc::channel(100);
/// ///
/// // Send the sender back to the application /// // Send the sender back to the application
/// output.send(Event::Ready(sender)).await; /// output.send(Event::Ready(sender)).await;
/// ///
/// // We are ready to receive messages /// loop {
/// state = State::Ready(receiver);
/// }
/// State::Ready(receiver) => {
/// use iced_futures::futures::StreamExt; /// use iced_futures::futures::StreamExt;
/// ///
/// // Read next input sent from `Application` /// // Read next input sent from `Application`
@ -408,8 +395,6 @@ where
/// } /// }
/// } /// }
/// } /// }
/// }
/// }
/// }) /// })
/// } /// }
/// ``` /// ```