Struct ChannelSignal 

pub struct ChannelSignal<T, E> { /* private fields */ }

A reactive signal for channels that produce multiple values with error handling.

ChannelSignal provides a way to reactively consume values from channels and automatically update UI when new values arrive or errors occur. It manages the channel lifecycle and provides access to both the current value and any errors.

Examples

// Simple case: std::thread executor, returns ChannelSignal<Option<T>, E>
let channel_signal = ChannelSignal::new(receiver);

// With initial value
let channel_signal = ChannelSignal::with_initial(receiver, initial_value);

// Full customization
let channel_signal = ChannelSignal::custom(receiver)
    .event_loop()
    .initial(initial_value)
    .build();

Implementations

impl<T: Send + 'static, E: Send + 'static> ChannelSignal<T, E>

pub fn new<R>(receiver: R) -> ChannelSignal<Option<T>, E>

where R: BlockingReceiver<Item = T, Error = E> + Send + 'static,

Creates a new reactive channel signal with sensible defaults.

• Executor: Std::thread for blocking receivers, event loop for pollable receivers
• Initial value: None (returns ChannelSignal<Option<U>, E>)

Parameters

• receiver - The channel receiver to consume.

Examples

let channel_signal = ChannelSignal::new(receiver);

pub fn new_poll<R>(receiver: R) -> ChannelSignal<Option<T>, E>

where R: PollableReceiver<Item = T, Error = E> + Send + 'static,

pub fn with_initial<R>(receiver: R, initial: T) -> Self

where R: BlockingReceiver<Item = T, Error = E> + Send + 'static,

Creates a new reactive channel signal with an initial value.

Uses the same defaults as new() but allows you to specify an initial value so the signal is never None.

• Executor: Std::thread for blocking receivers, event loop for pollable receivers

Parameters

• receiver - The channel receiver to consume.
• initial - The initial value for the signal before any message arrives.

Examples

let channel_signal = ChannelSignal::with_initial(receiver, initial_value);

pub fn custom<R>( receiver: R, ) -> ChannelSignalBuilder<R, T, E, StdThreadExecutor, NoInitial>

where T: Send + 'static, E: Send + 'static,

Creates a channel signal builder for full customization.

Use this when you need to customize:

• The executor (event loop, tokio, std::thread, etc.)
• Initial value

Examples

// Event loop executor with initial value
let channel_signal = ChannelSignal::custom(receiver)
    .event_loop()
    .initial(initial_value)
    .build();

pub fn error(&self) -> ReadSignal<Option<E>>

Trait Implementations

impl<T, E> Clone for ChannelSignal<T, E>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Send + 'static> From<Receiver<T>> for ChannelSignal<Option<T>, RecvError>

This implementation will be removed in the future

fn from(value: Receiver<T>) -> Self

Converts to this type from the input type.

impl<T, E> SignalGet<T> for ChannelSignal<T, E>

where T: Clone,

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, E> SignalRead<T> for ChannelSignal<T, E>

fn id(&self) -> ReactiveId

get the Signal Id

fn try_read(&self) -> Option<ReadRef<'_, 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<'_, 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, E> SignalTrack<T> for ChannelSignal<T, E>

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, E> SignalWith<T> for ChannelSignal<T, E>

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, E> Copy for ChannelSignal<T, E>