Struct seitan::StreamRc[][src]

#[must_use = "droping a stream unsubscribes it and all the chain until the origin sender"]
pub struct StreamRc<'a, T2> { /* fields omitted */ }

Implementations

impl<'a, T2> StreamRc<'a, T2>[src]

pub fn from_parent<'p, T1, S: StreamExt<'p, T1>, Inner: StreamInner<'a, T2> + SinkInner<'a, T1> + 'a>(
    parent: S,
    inner: Rc<UnsafeCell<Inner>>
) -> StreamRc<'a, T2>
[src]

pub fn from_remove<'p, T1, S: Remove + 'a, Inner: StreamInner<'a, T2> + SinkInner<'a, T1> + 'a>(
    remove: S,
    inner: Rc<UnsafeCell<Inner>>
) -> StreamRc<'a, T2>
[src]

pub fn new<Inner: StreamInner<'a, T2> + 'a>(
    inner: Rc<UnsafeCell<Inner>>
) -> StreamRc<'a, T2>
[src]

pub fn send(&self, t: T2)[src]

pub fn on_drop(self, value: T2) -> StreamRc<'a, T2>[src]

pub fn by_ref(&self) -> &Self where
    Self: Sized
[src]

impl<'a, T2: Clone + 'a> StreamRc<'a, T2>[src]

pub fn never() -> StreamRc<'a, T2>[src]

pub fn merge_all<'b, S, I>(streams: I) -> StreamRc<'a, T2> where
    S: StreamExt<'b, T2>,
    I: IntoIterator<Item = S>, 
[src]

pub fn swap_parent<S: StreamExt<'a, T2>>(&mut self, parent: S)[src]

impl<'a, T2: Clone> StreamRc<'a, T2>[src]

pub fn connect_to_property<'b, 'c>(
    self,
    property: &mut Property<'a, T2>
) -> StreamRc<'a, T2> where
    T2: 'c,
    Self: Sized
[src]

impl<'a> StreamRc<'a, f64>[src]

pub fn connect_to_ranged_parameter_pct<T, R>(
    self,
    param: &mut RangedPropertyMut<'a, T, R>
) -> StreamRc<'a, T> where
    T: Clone + 'a + FromPrimitive + ToPrimitive,
    R: Sub<Output = R> + ToPrimitive + Clone + 'static, 
[src]

impl<'a> StreamRc<'a, bool>[src]

pub fn not<'b>(self) -> Stream<'b, bool> where
    'a: 'b, 
[src]

pub fn and_then<T: Clone + 'a, S: StreamExt<'a, T>>(
    self,
    then: S
) -> Stream<'a, T>
[src]

pub fn switch<T: 'a + Clone, S: StreamExt<'a, T>>(
    self,
    then: S,
    else_: S
) -> Stream<'a, T>
[src]

Trait Implementations

impl<'a, T2> Clone for StreamRc<'a, T2>[src]

impl<'a, T2> Drop for StreamRc<'a, T2>[src]

impl<'a, T: Clone + 'a> From<Stream<'a, T>> for StreamRc<'a, T>[src]

impl<'a, T: 'a> From<StreamRc<'a, T>> for Stream<'a, T>[src]

impl<'a> Not for StreamRc<'a, bool>[src]

type Output = Stream<'a, bool>

The resulting type after applying the ! operator.

impl<'a, T: 'a> StreamExt<'a, T> for StreamRc<'a, T>[src]

Auto Trait Implementations

impl<'a, T2> !RefUnwindSafe for StreamRc<'a, T2>

impl<'a, T2> !Send for StreamRc<'a, T2>

impl<'a, T2> !Sync for StreamRc<'a, T2>

impl<'a, T2> Unpin for StreamRc<'a, T2>

impl<'a, T2> !UnwindSafe for StreamRc<'a, T2>

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> Pointable for T[src]

type Init = T

The type for initializers.

impl<T> ToOwned for T where
    T: Clone
[src]

type Owned = T

The resulting type after obtaining ownership.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

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

The type returned in the event of a conversion error.