Struct moxie::runtime::RunLoop[−][src]

pub struct RunLoop<Root> { /* fields omitted */ }

Expand description

A Runtime that is bound with a particular root function.

If running in a context with an async executor, can be consumed as a [futures::Stream] of crate::runtime::Revisions in order to provide the super::Runtime with a std::task::Waker.

Implementations

[src]

impl<Root, Out> RunLoop<Root> where
Root: FnMut() -> Out + Unpin,

[src]

pub fn new(root: Root) -> RunLoop<Root>

Creates a new Runtime attached to the provided root function.

[src]

pub fn revision(&self) -> Revision

Returns the runtime’s current Revision.

[src]

pub fn set_state_change_waker(&mut self, wk: Waker)

Sets the std::task::Waker which will be called when state variables change.

[src]

pub fn set_task_executor(&mut self, sp: impl LocalSpawn + 'static)

Sets the executor that will be used to spawn normal priority tasks.

[src]

pub fn run_once(&mut self) -> Out

Run the root function once within this runtime’s context, returning the result.

[src]

pub async fn run_on_state_changes(self)

Poll this runtime without exiting. Discards any value returned from the root function. The future yields in between revisions and is woken on state changes.

[src]

pub fn unloop(self) -> (Runtime, Root)

Unbinds the runtime from its current root function, returning both.

Trait Implementations

[src]

impl<Root, Out> Stream for RunLoop<Root> where
Root: FnMut() -> Out + Unpin,

[src]

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

This Stream implementation runs a single revision for each call to poll_next, always returning Poll::Ready(Some(...)).

type Item = (Revision, Out)

Values yielded by the stream.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream. Read more

Auto Trait Implementations

impl<Root> !RefUnwindSafe for RunLoop<Root>

impl<Root> !Send for RunLoop<Root>

impl<Root> !Sync for RunLoop<Root>

impl<Root> Unpin for RunLoop<Root> where
Root: Unpin,

impl<Root> !UnwindSafe for RunLoop<Root>

Blanket Implementations

[src]

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

[src]

pub fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

[src]

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

[src]

pub fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

[src]

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

[src]

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

Mutably borrows from an owned value. Read more

impl<T> Downcast for T where
T: Any,

pub fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>

Convert Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can then be further downcast into Box<ConcreteType> where ConcreteType implements Trait. Read more

pub fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>

Convert Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait. Read more

pub fn as_any(&self) -> &(dyn Any + 'static)

Convert &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s. Read more

pub fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Convert &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s. Read more

[src]

impl<T> From<T> for T

[src]

pub fn from(t: T) -> T

Performs the conversion.

[src]

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

[src]

pub fn into(self) -> U

Performs the conversion.

impl<T> StreamExt for T where
T: Stream + ?Sized,

fn next(&mut self) -> Next<'_, Self> where
Self: Unpin,

Creates a future that resolves to the next item in the stream. Read more

fn into_future(self) -> StreamFuture<Self> where
Self: Unpin,

Converts this stream into a future of (next_item, tail_of_stream). If the stream terminates, then the next item is None. Read more

fn map<T, F>(self, f: F) -> Map<Self, F> where
F: FnMut(Self::Item) -> T,

Maps this stream’s items to a different type, returning a new stream of the resulting type. Read more

fn enumerate(self) -> Enumerate<Self>

Creates a stream which gives the current iteration count as well as the next value. Read more

fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F> where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,

Filters the values produced by this stream according to the provided asynchronous predicate. Read more

fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = Option<T>>,

Filters the values produced by this stream while simultaneously mapping them to a different type according to the provided asynchronous closure. Read more

fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future,

Computes from this stream’s items new items of a different type using an asynchronous closure. Read more

fn collect<C>(self) -> Collect<Self, C> where
C: Default + Extend<Self::Item>,

Transforms a stream into a collection, returning a future representing the result of that computation. Read more

fn unzip<A, B, FromA, FromB>(self) -> Unzip<Self, FromA, FromB> where
 FromA: Default + Extend<A>,
 FromB: Default + Extend,
 Self: Stream<Item = (A, B)>,

Converts a stream of pairs into a future, which resolves to pair of containers. Read more

fn concat(self) -> Concat<Self> where
 Self::Item: Extend<<Self::Item as IntoIterator>::Item>,
 Self::Item: IntoIterator,
 Self::Item: Default,

Concatenate all items of a stream into a single extendable destination, returning a future representing the end result. Read more

fn cycle(self) -> Cycle<Self> where
Self: Clone,

Repeats a stream endlessly. Read more

fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F> where
F: FnMut(T, Self::Item) -> Fut,
Fut: Future<Output = T>,

Execute an accumulating asynchronous computation over a stream, collecting all the values into one final result. Read more

fn any<Fut, F>(self, f: F) -> Any<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = bool>,

Execute predicate over asynchronous stream, and return true if any element in stream satisfied a predicate. Read more

fn all<Fut, F>(self, f: F) -> All<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = bool>,

Execute predicate over asynchronous stream, and return true if all element in stream satisfied a predicate. Read more

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

Flattens a stream of streams into just one continuous stream. Read more

fn flat_map<U, F>(self, f: F) -> FlatMap<Self, U, F> where
F: FnMut(Self::Item) -> U,
U: Stream,

Maps a stream like [StreamExt::map] but flattens nested Streams. Read more

fn scan<S, B, Fut, F>(self, initial_state: S, f: F) -> Scan<Self, S, Fut, F> where
F: FnMut(&mut S, Self::Item) -> Fut,
Fut: Future<Output = Option>,

Combinator similar to [StreamExt::fold] that holds internal state and produces a new stream. Read more

fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F> where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,

Skip elements on this stream while the provided asynchronous predicate resolves to true. Read more

fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F> where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,

Take elements from this stream while the provided asynchronous predicate resolves to true. Read more

fn take_until<Fut>(self, fut: Fut) -> TakeUntil<Self, Fut> where
Fut: Future,

Take elements from this stream until the provided future resolves. Read more

fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = ()>,

Runs this stream to completion, executing the provided asynchronous closure for each element on the stream. Read more

fn for_each_concurrent<Fut, F>(
 self,
 limit: impl Into<Option<usize>>,
 f: F
) -> ForEachConcurrent<Self, Fut, F> where
 F: FnMut(Self::Item) -> Fut,
 Fut: Future<Output = ()>,

Runs this stream to completion, executing the provided asynchronous closure for each element on the stream concurrently as elements become available. Read more

fn take(self, n: usize) -> Take<Self>

Creates a new stream of at most n items of the underlying stream. Read more

fn skip(self, n: usize) -> Skip<Self>

Creates a new stream which skips n items of the underlying stream. Read more

fn fuse(self) -> Fuse<Self>

Fuse a stream such that poll_next will never again be called once it has finished. This method can be used to turn any Stream into a FusedStream. Read more

fn by_ref(&mut self) -> &mut Self

Borrows a stream, rather than consuming it. Read more

fn catch_unwind(self) -> CatchUnwind<Self> where
Self: UnwindSafe,

Catches unwinding panics while polling the stream. Read more

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

Wrap the stream in a Box, pinning it. Read more

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

Wrap the stream in a Box, pinning it. Read more

fn buffered(self, n: usize) -> Buffered<Self> where
Self::Item: Future,

An adaptor for creating a buffered list of pending futures. Read more

fn buffer_unordered(self, n: usize) -> BufferUnordered<Self> where
Self::Item: Future,

An adaptor for creating a buffered list of pending futures (unordered). Read more

fn zip<St>(self, other: St) -> Zip<Self, St> where
St: Stream,

An adapter for zipping two streams together. Read more

fn chain<St>(self, other: St) -> Chain<Self, St> where
St: Stream<Item = Self::Item>,

Adapter for chaining two streams. Read more

fn peekable(self) -> Peekable<Self>

Creates a new stream which exposes a peek method. Read more

fn chunks(self, capacity: usize) -> Chunks<Self>

An adaptor for chunking up items of the stream inside a vector. Read more

fn ready_chunks(self, capacity: usize) -> ReadyChunks<Self>

An adaptor for chunking up ready items of the stream inside a vector. Read more

fn forward<S>(self, sink: S) -> Forward<Self, S> where
S: Sink<Self::Ok, Error = Self::Error>,
Self: TryStream,

A future that completes after the given stream has been fully processed into the sink and the sink has been flushed and closed. Read more

fn split<Item>(self) -> (SplitSink<Self, Item>, SplitStream<Self>) where
Self: Sink<Item>,

Splits this Stream + Sink object into separate Sink and Stream objects. Read more

fn inspect<F>(self, f: F) -> Inspect<Self, F> where
F: FnMut(&Self::Item),

Do something with each item of this stream, afterwards passing it on. Read more

fn left_stream(self) -> Either<Self, B> where
B: Stream<Item = Self::Item>,

Wrap this stream in an Either stream, making it the left-hand variant of that Either. Read more

fn right_stream(self) -> Either<B, Self> where
B: Stream<Item = Self::Item>,

Wrap this stream in an Either stream, making it the right-hand variant of that Either. Read more

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

A convenience method for calling [Stream::poll_next] on Unpin stream types. Read more

fn select_next_some(&mut self) -> SelectNextSome<'_, Self> where
Self: Unpin + FusedStream,

Returns a Future that resolves when the next item in this stream is ready. Read more

[src]

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

type Error = Infallible

The type returned in the event of a conversion error.

[src]

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

Performs the conversion.

[src]

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

type Error = >::Error

The type returned in the event of a conversion error.

[src]

pub fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

Struct moxie::runtime::RunLoop[−][src]

Implementations

impl<Root, Out> RunLoop<Root> where Root: FnMut() -> Out + Unpin,

pub fn new(root: Root) -> RunLoop<Root>

pub fn revision(&self) -> Revision

pub fn set_state_change_waker(&mut self, wk: Waker)

pub fn set_task_executor(&mut self, sp: impl LocalSpawn + 'static)

pub fn run_once(&mut self) -> Out

pub async fn run_on_state_changes(self)

pub fn unloop(self) -> (Runtime, Root)

Trait Implementations

impl<Root, Out> Stream for RunLoop<Root> where Root: FnMut() -> Out + Unpin,

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

type Item = (Revision, Out)

fn size_hint(&self) -> (usize, Option<usize>)

Auto Trait Implementations

impl<Root> !RefUnwindSafe for RunLoop<Root>

impl<Root> !Send for RunLoop<Root>

impl<Root> !Sync for RunLoop<Root>

impl<Root> Unpin for RunLoop<Root> where Root: Unpin,

impl<Root> !UnwindSafe for RunLoop<Root>

Blanket Implementations

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

pub fn type_id(&self) -> TypeId

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

pub fn borrow(&self) -> &T

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

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

impl<T> Downcast for T where T: Any,

pub fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>

pub fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>

pub fn as_any(&self) -> &(dyn Any + 'static)

pub fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

impl<T> From<T> for T

pub fn from(t: T) -> T

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

pub fn into(self) -> U

impl<T> StreamExt for T where T: Stream + ?Sized,

fn next(&mut self) -> Next<'_, Self> where Self: Unpin,

fn into_future(self) -> StreamFuture<Self> where Self: Unpin,

fn map<T, F>(self, f: F) -> Map<Self, F> where F: FnMut(Self::Item) -> T,

fn enumerate(self) -> Enumerate<Self>

fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F> where F: FnMut(&Self::Item) -> Fut, Fut: Future<Output = bool>,

fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F> where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = Option<T>>,

fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> where F: FnMut(Self::Item) -> Fut, Fut: Future,

fn collect<C>(self) -> Collect<Self, C> where C: Default + Extend<Self::Item>,

fn unzip<A, B, FromA, FromB>(self) -> Unzip<Self, FromA, FromB> where FromA: Default + Extend<A>, FromB: Default + Extend<B>, Self: Stream<Item = (A, B)>,

fn concat(self) -> Concat<Self> where Self::Item: Extend<<Self::Item as IntoIterator>::Item>, Self::Item: IntoIterator, Self::Item: Default,

fn cycle(self) -> Cycle<Self> where Self: Clone,

fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F> where F: FnMut(T, Self::Item) -> Fut, Fut: Future<Output = T>,

fn any<Fut, F>(self, f: F) -> Any<Self, Fut, F> where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = bool>,

fn all<Fut, F>(self, f: F) -> All<Self, Fut, F> where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = bool>,

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

fn flat_map<U, F>(self, f: F) -> FlatMap<Self, U, F> where F: FnMut(Self::Item) -> U, U: Stream,

fn scan<S, B, Fut, F>(self, initial_state: S, f: F) -> Scan<Self, S, Fut, F> where F: FnMut(&mut S, Self::Item) -> Fut, Fut: Future<Output = Option<B>>,

fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F> where F: FnMut(&Self::Item) -> Fut, Fut: Future<Output = bool>,

fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F> where F: FnMut(&Self::Item) -> Fut, Fut: Future<Output = bool>,

fn take_until<Fut>(self, fut: Fut) -> TakeUntil<Self, Fut> where Fut: Future,

fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F> where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = ()>,

fn for_each_concurrent<Fut, F>( self, limit: impl Into<Option<usize>>, f: F) -> ForEachConcurrent<Self, Fut, F> where F: FnMut(Self::Item) -> Fut, Fut: Future<Output = ()>,

fn take(self, n: usize) -> Take<Self>

fn skip(self, n: usize) -> Skip<Self>

fn fuse(self) -> Fuse<Self>

fn by_ref(&mut self) -> &mut Self

fn catch_unwind(self) -> CatchUnwind<Self> where Self: UnwindSafe,

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

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

fn buffered(self, n: usize) -> Buffered<Self> where Self::Item: Future,

fn buffer_unordered(self, n: usize) -> BufferUnordered<Self> where Self::Item: Future,

fn zip<St>(self, other: St) -> Zip<Self, St> where St: Stream,

fn chain<St>(self, other: St) -> Chain<Self, St> where St: Stream<Item = Self::Item>,

fn peekable(self) -> Peekable<Self>

fn chunks(self, capacity: usize) -> Chunks<Self>

fn ready_chunks(self, capacity: usize) -> ReadyChunks<Self>

fn forward<S>(self, sink: S) -> Forward<Self, S> where S: Sink<Self::Ok, Error = Self::Error>, Self: TryStream,

fn split<Item>(self) -> (SplitSink<Self, Item>, SplitStream<Self>) where Self: Sink<Item>,

fn inspect<F>(self, f: F) -> Inspect<Self, F> where F: FnMut(&Self::Item),

fn left_stream<B>(self) -> Either<Self, B> where B: Stream<Item = Self::Item>,

fn right_stream<B>(self) -> Either<B, Self> where B: Stream<Item = Self::Item>,

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

impl<Root, Out> RunLoop<Root> where
Root: FnMut() -> Out + Unpin,

impl<Root, Out> Stream for RunLoop<Root> where
Root: FnMut() -> Out + Unpin,

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

impl<Root> Unpin for RunLoop<Root> where
Root: Unpin,

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

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

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

impl<T> Downcast for T where
T: Any,

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

impl<T> StreamExt for T where
T: Stream + ?Sized,

fn next(&mut self) -> Next<'_, Self> where
Self: Unpin,

fn into_future(self) -> StreamFuture<Self> where
Self: Unpin,

fn map<T, F>(self, f: F) -> Map<Self, F> where
F: FnMut(Self::Item) -> T,

fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F> where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,

fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = Option<T>>,

fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future,

fn collect<C>(self) -> Collect<Self, C> where
C: Default + Extend<Self::Item>,

fn unzip<A, B, FromA, FromB>(self) -> Unzip<Self, FromA, FromB> where
FromA: Default + Extend<A>,
FromB: Default + Extend<B>,
Self: Stream<Item = (A, B)>,

fn concat(self) -> Concat<Self> where
Self::Item: Extend<<Self::Item as IntoIterator>::Item>,
Self::Item: IntoIterator,
Self::Item: Default,

fn cycle(self) -> Cycle<Self> where
Self: Clone,

fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F> where
F: FnMut(T, Self::Item) -> Fut,
Fut: Future<Output = T>,

fn any<Fut, F>(self, f: F) -> Any<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = bool>,

fn all<Fut, F>(self, f: F) -> All<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = bool>,

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

fn flat_map<U, F>(self, f: F) -> FlatMap<Self, U, F> where
F: FnMut(Self::Item) -> U,
U: Stream,

fn scan<S, B, Fut, F>(self, initial_state: S, f: F) -> Scan<Self, S, Fut, F> where
F: FnMut(&mut S, Self::Item) -> Fut,
Fut: Future<Output = Option<B>>,

fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F> where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,

fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F> where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,

fn take_until<Fut>(self, fut: Fut) -> TakeUntil<Self, Fut> where
Fut: Future,

fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = ()>,

fn for_each_concurrent<Fut, F>(
self,
limit: impl Into<Option<usize>>,
f: F
) -> ForEachConcurrent<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = ()>,

fn catch_unwind(self) -> CatchUnwind<Self> where
Self: UnwindSafe,

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

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

fn buffered(self, n: usize) -> Buffered<Self> where
Self::Item: Future,

fn buffer_unordered(self, n: usize) -> BufferUnordered<Self> where
Self::Item: Future,

fn zip<St>(self, other: St) -> Zip<Self, St> where
St: Stream,

fn chain<St>(self, other: St) -> Chain<Self, St> where
St: Stream<Item = Self::Item>,

fn forward<S>(self, sink: S) -> Forward<Self, S> where
S: Sink<Self::Ok, Error = Self::Error>,
Self: TryStream,

fn split<Item>(self) -> (SplitSink<Self, Item>, SplitStream<Self>) where
Self: Sink<Item>,

fn inspect<F>(self, f: F) -> Inspect<Self, F> where
F: FnMut(&Self::Item),

fn left_stream<B>(self) -> Either<Self, B> where
B: Stream<Item = Self::Item>,

fn right_stream<B>(self) -> Either<B, Self> where
B: Stream<Item = Self::Item>,

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

fn select_next_some(&mut self) -> SelectNextSome<'_, Self> where
Self: Unpin + FusedStream,

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

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