diff options
| -rw-r--r-- | native/src/subscription.rs | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/native/src/subscription.rs b/native/src/subscription.rs index 7a1c5852..420797d1 100644 --- a/native/src/subscription.rs +++ b/native/src/subscription.rs @@ -84,6 +84,25 @@ where }) } +/// Returns a [`Subscription`] that will create and asynchronously run the +/// [`Stream`] returned by the provided closure. +/// +/// The `initial` state will be used to uniquely identify the [`Subscription`]. +pub fn run<T, S, Message>( + initial: T, + f: impl FnOnce(T) -> S + 'static, +) -> Subscription<Message> +where + Message: 'static, + T: Clone + Hash + 'static, + S: Stream<Item = Message> + Send + 'static, +{ + Subscription::from_recipe(Runner { + initial, + spawn: move |initial, _| f(initial), + }) +} + struct Runner<T, F, S, Message> where F: FnOnce(T, EventStream) -> S, |