Struct FutureSignal 

pub struct FutureSignal<T> { /* private fields */ }

A reactive signal for futures that resolve to a single value.

FutureSignal provides a way to reactively consume values from async futures and automatically update UI when the future completes. It manages the future lifecycle and provides access to both the current value and completion state.

The value is always Option<T> where None means the future hasn’t completed yet and Some(T) means the future has completed with the result.

Examples

// Simple case: event loop executor
let future_signal = FutureSignal::new(my_future);

// Full customization
let future_signal = FutureSignal::custom(my_future)
    .tokio_spawn()
    .build();

Implementations

impl<T: 'static> FutureSignal<T>

pub fn new<Fut>(future: Fut) -> Self

where Fut: Future<Output = T> + 'static, T: 'static,

Creates a new reactive future signal with sensible defaults.

• Executor: Main event loop (future does not need to be Send)
• Initial value: Always None until the future completes

Parameters

• future - The async future to consume.

Examples

let future_signal = FutureSignal::new(my_future);

pub fn custom<Fut>( future: Fut, ) -> FutureSignalBuilder<Fut, T, EventLoopExecutor>

where Fut: Future<Output = T> + 'static, T: 'static,

Creates a future signal builder for full customization.

Use this when you need to customize:

• The executor (tokio, custom, etc.)

Examples

// Tokio executor
let future_signal = FutureSignal::custom(my_future)
    .tokio_spawn()
    .build();

pub fn is_finished(&self) -> bool

Trait Implementations

impl<T> Clone for FutureSignal<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Clone> SignalGet<Option<T>> for FutureSignal<T>

fn id(&self) -> ReactiveId

get the Signal Id

fn get_untracked(&self) -> T

where T: 'static,

fn get(&self) -> T

where T: 'static,

fn try_get(&self) -> Option<T>

where T: 'static,

fn try_get_untracked(&self) -> Option<T>

where T: 'static,

impl<T> SignalRead<Option<T>> for FutureSignal<T>

fn id(&self) -> ReactiveId

get the Signal Id

fn try_read(&self) -> Option<ReadRef<'_, Option<T>>>

where T: 'static,

If the signal isn’t disposed, reads the data stored in the Signal and subscribes to the current running effect.

fn try_read_untracked(&self) -> Option<ReadRef<'_, Option<T>>>

where T: 'static,

If the signal isn’t disposed, reads the data stored in the Signal without subscribing.

fn read(&self) -> ReadRef<'_, T>

where T: 'static,

Reads the data stored in the Signal, subscribing the current running effect.

fn read_untracked(&self) -> ReadRef<'_, T>

where T: 'static,

Reads the data stored in the Signal without subscribing.

impl<T> SignalTrack<Option<T>> for FutureSignal<T>

fn id(&self) -> ReactiveId

fn track(&self)

Only subscribes to the current running effect to this Signal.

fn try_track(&self)

If the signal isn’t disposed,

impl<T> SignalWith<Option<T>> for FutureSignal<T>

fn id(&self) -> ReactiveId

get the Signal Id

fn with<O>(&self, f: impl FnOnce(&T) -> O) -> O

where T: 'static,

fn with_untracked<O>(&self, f: impl FnOnce(&T) -> O) -> O

where T: 'static,

fn try_with<O>(&self, f: impl FnOnce(Option<&T>) -> O) -> O

where T: 'static,

fn try_with_untracked<O>(&self, f: impl FnOnce(Option<&T>) -> O) -> O

where T: 'static,

impl<T> Copy for FutureSignal<T>