Struct futures_signals::signal::DedupeMap

pub struct DedupeMap<A, B>where
    A: Signal,{ /* private fields */ }

Trait Implementations§

Formats the value using the given formatter. Read more

§

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Returns the argument unchanged.

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Creates a Stream which contains the values of self. Read more

Creates a Signal which uses a closure to transform the value. Read more

Creates a Signal which uses a closure to transform the value. Read more

Creates a Signal which uses a closure to asynchronously transform the value. Read more

Creates a Signal which uses a closure to filter and transform the value. Read more

Creates a Signal which delays updates until a Future finishes. Read more

Creates a Signal which flattens self. Read more

Creates a Stream which samples the value of self whenever the Stream has a new value. Read more

Conditionally stops the Signal. Read more

A convenience for calling Signal::poll_change on Unpin types.

§

The type returned in the event of a conversion error.

Performs the conversion.

§

The type returned in the event of a conversion error.

Performs the conversion.

Struct futures_signals::signal::DedupeMap

Trait Implementations§

impl<A, B: Debug> Debug for DedupeMap<A, B>where A: Signal + Debug, A::Item: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

impl<A, B, C> Signal for DedupeMap<A, B>where A: Signal, A::Item: PartialEq, B: FnMut(&mut A::Item) -> C,

type Item = C

fn poll_change( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Option<Self::Item>>

impl<'pin, A, B> Unpin for DedupeMap<A, B>where A: Signal, __DedupeMap<'pin, A, B>: Unpin,

Auto Trait Implementations§

impl<A, B> RefUnwindSafe for DedupeMap<A, B>where A: RefUnwindSafe, B: RefUnwindSafe, <A as Signal>::Item: RefUnwindSafe,

impl<A, B> Send for DedupeMap<A, B>where A: Send, B: Send, <A as Signal>::Item: Send,

impl<A, B> Sync for DedupeMap<A, B>where A: Sync, B: Sync, <A as Signal>::Item: Sync,

impl<A, B> UnwindSafe for DedupeMap<A, B>where A: UnwindSafe, B: UnwindSafe, <A as Signal>::Item: UnwindSafe,

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> SignalExt for Twhere T: Signal + ?Sized,

fn to_stream(self) -> SignalStream<Self>where Self: Sized,

fn to_future(self) -> SignalFuture<Self> ⓘwhere Self: Sized,

fn map<A, B>(self, callback: B) -> Map<Self, B>where B: FnMut(Self::Item) -> A, Self: Sized,

fn inspect<A>(self, callback: A) -> Inspect<Self, A>where A: FnMut(&Self::Item), Self: Sized,

fn eq(self, value: Self::Item) -> Eq<Self>where Self::Item: PartialEq, Self: Sized,

fn neq(self, value: Self::Item) -> Neq<Self>where Self::Item: PartialEq, Self: Sized,

fn dedupe_map<A, B>(self, callback: B) -> DedupeMap<Self, B>where B: FnMut(&mut Self::Item) -> A, Self::Item: PartialEq, Self: Sized,

fn dedupe(self) -> Dedupe<Self>where Self::Item: PartialEq, Self: Sized,

fn dedupe_cloned(self) -> DedupeCloned<Self>where Self::Item: PartialEq, Self: Sized,

fn map_future<A, B>(self, callback: B) -> MapFuture<Self, A, B>where A: Future, B: FnMut(Self::Item) -> A, Self: Sized,

fn filter_map<A, B>(self, callback: B) -> FilterMap<Self, B>where B: FnMut(Self::Item) -> Option<A>, Self: Sized,

fn throttle<A, B>(self, callback: B) -> Throttle<Self, A, B>where A: Future<Output = ()>, B: FnMut() -> A, Self: Sized,

fn flatten(self) -> Flatten<Self>where Self::Item: Signal, Self: Sized,

fn switch<A, B>(self, callback: B) -> Switch<Self, A, B>where A: Signal, B: FnMut(Self::Item) -> A, Self: Sized,

fn switch_signal_vec<A, F>(self, callback: F) -> SwitchSignalVec<Self, A, F>where A: SignalVec, F: FnMut(Self::Item) -> A, Self: Sized,

fn sample_stream_cloned<A>(self, stream: A) -> SampleStreamCloned<Self, A>where A: Stream, A::Item: Clone, Self: Sized,

fn for_each<U, F>(self, callback: F) -> ForEach<Self, U, F> ⓘwhere U: Future<Output = ()>, F: FnMut(Self::Item) -> U, Self: Sized,

fn to_signal_vec(self) -> SignalSignalVec<Self>where Self: Sized,

fn wait_for(self, value: Self::Item) -> WaitFor<Self> ⓘwhere Self::Item: PartialEq, Self: Sized,

fn first(self) -> First<Self>where Self: Sized,

fn stop_if<F>(self, test: F) -> StopIf<Self, F>where F: FnMut(&Self::Item) -> bool, Self: Sized,

fn debug(self) -> SignalDebug<Self>where Self: Sized, Self::Item: Debug,

fn broadcast(self) -> Broadcaster<Self>where Self: Sized,

fn poll_change_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Option<Self::Item>>where Self: Unpin + Sized,

fn boxed<'a>(self) -> Pin<Box<dyn Signal<Item = Self::Item> + Send + 'a>>where Self: Sized + Send + 'a,

fn boxed_local<'a>(self) -> Pin<Box<dyn Signal<Item = Self::Item> + 'a>>where Self: Sized + 'a,

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>