Trait ux::prelude::PollableInputStreamExtManual[−]

pub trait PollableInputStreamExtManual {
    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 read_nonblocking<C>(
        &self, 
        buffer: &mut [u8], 
        cancellable: Option<&C>
    ) -> Result<isize, Error>
    where
        C: IsA<Cancellable>;

    pub fn into_async_read(self) -> Result<InputStreamAsyncRead<Self>, Self>
    where
        Self: IsA<PollableInputStream>,
    { ... }
}

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, 

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 read_nonblocking<C>(
    &self,
    buffer: &mut [u8],
    cancellable: Option<&C>
) -> Result<isize, Error> where
    C: IsA<Cancellable>, 

Loading content...

Provided methods

pub fn into_async_read(self) -> Result<InputStreamAsyncRead<Self>, Self> where
    Self: IsA<PollableInputStream>, 

Loading content...

Implementors

impl<O> PollableInputStreamExtManual for O where
    O: IsA<PollableInputStream>, 

Loading content...