Trait ux::prelude::PollableOutputStreamExtManual [−]
pub trait PollableOutputStreamExtManual {
pub fn create_source<F, C>(
&self,
cancellable: Option<&C>,
name: Option<&str>,
priority: Priority,
func: F
) -> Source
where
C: IsA<Cancellable>,
F: FnMut(&Self) -> Continue + 'static;
pub fn create_source_future<C>(
&self,
cancellable: Option<&C>,
priority: Priority
) -> Pin<Box<dyn Future<Output = ()> + 'static, Global>>
where
C: IsA<Cancellable>;
pub fn create_source_stream<C>(
&self,
cancellable: Option<&C>,
priority: Priority
) -> Pin<Box<dyn Stream<Item = ()> + 'static, Global>>
where
C: IsA<Cancellable>;
pub fn into_async_write(self) -> Result<OutputStreamAsyncWrite<Self>, Self>
where
Self: IsA<PollableOutputStream>,
{ ... }
}Required methods
pub fn create_source<F, C>(
&self,
cancellable: Option<&C>,
name: Option<&str>,
priority: Priority,
func: F
) -> Source where
C: IsA<Cancellable>,
F: FnMut(&Self) -> Continue + 'static,
&self,
cancellable: Option<&C>,
name: Option<&str>,
priority: Priority,
func: F
) -> Source where
C: IsA<Cancellable>,
F: FnMut(&Self) -> Continue + 'static,
pub fn create_source_future<C>(
&self,
cancellable: Option<&C>,
priority: Priority
) -> Pin<Box<dyn Future<Output = ()> + 'static, Global>> where
C: IsA<Cancellable>,
&self,
cancellable: Option<&C>,
priority: Priority
) -> Pin<Box<dyn Future<Output = ()> + 'static, Global>> where
C: IsA<Cancellable>,
pub fn create_source_stream<C>(
&self,
cancellable: Option<&C>,
priority: Priority
) -> Pin<Box<dyn Stream<Item = ()> + 'static, Global>> where
C: IsA<Cancellable>,
&self,
cancellable: Option<&C>,
priority: Priority
) -> Pin<Box<dyn Stream<Item = ()> + 'static, Global>> where
C: IsA<Cancellable>,
Provided methods
pub fn into_async_write(self) -> Result<OutputStreamAsyncWrite<Self>, Self> where
Self: IsA<PollableOutputStream>,
Self: IsA<PollableOutputStream>,
Implementors
impl<O> PollableOutputStreamExtManual for O where
O: IsA<PollableOutputStream>,
O: IsA<PollableOutputStream>,
pub fn create_source<F, C>(
&self,
cancellable: Option<&C>,
name: Option<&str>,
priority: Priority,
func: F
) -> Source where
C: IsA<Cancellable>,
F: FnMut(&O) -> Continue + 'static,
&self,
cancellable: Option<&C>,
name: Option<&str>,
priority: Priority,
func: F
) -> Source where
C: IsA<Cancellable>,
F: FnMut(&O) -> Continue + 'static,
pub fn create_source_future<C>(
&self,
cancellable: Option<&C>,
priority: Priority
) -> Pin<Box<dyn Future<Output = ()> + 'static, Global>> where
C: IsA<Cancellable>,
&self,
cancellable: Option<&C>,
priority: Priority
) -> Pin<Box<dyn Future<Output = ()> + 'static, Global>> where
C: IsA<Cancellable>,
pub fn create_source_stream<C>(
&self,
cancellable: Option<&C>,
priority: Priority
) -> Pin<Box<dyn Stream<Item = ()> + 'static, Global>> where
C: IsA<Cancellable>,
&self,
cancellable: Option<&C>,
priority: Priority
) -> Pin<Box<dyn Stream<Item = ()> + 'static, Global>> where
C: IsA<Cancellable>,