Trait ux::prelude::BufferedInputStreamExt [−]
pub trait BufferedInputStreamExt: 'static {
pub fn fill<P>(
&self,
count: isize,
cancellable: Option<&P>
) -> Result<isize, Error>
where
P: IsA<Cancellable>;
pub fn fill_async<P, Q>(
&self,
count: isize,
io_priority: Priority,
cancellable: Option<&P>,
callback: Q
)
where
P: IsA<Cancellable>,
Q: 'static + FnOnce(Result<isize, Error>) + Send;
pub fn fill_async_future(
&self,
count: isize,
io_priority: Priority
) -> Pin<Box<dyn Future<Output = Result<isize, Error>> + 'static, Global>>;
pub fn get_available(&self) -> usize;
pub fn get_buffer_size(&self) -> usize;
pub fn peek_buffer(&self) -> Vec<u8, Global>;
pub fn read_byte<P>(&self, cancellable: Option<&P>) -> Result<i32, Error>
where
P: IsA<Cancellable>;
pub fn set_buffer_size(&self, size: usize);
pub fn connect_property_buffer_size_notify<F>(
&self,
f: F
) -> SignalHandlerId
where
F: 'static + Fn(&Self);
}Required methods
pub fn fill<P>(
&self,
count: isize,
cancellable: Option<&P>
) -> Result<isize, Error> where
P: IsA<Cancellable>,
&self,
count: isize,
cancellable: Option<&P>
) -> Result<isize, Error> where
P: IsA<Cancellable>,
pub fn fill_async<P, Q>(
&self,
count: isize,
io_priority: Priority,
cancellable: Option<&P>,
callback: Q
) where
P: IsA<Cancellable>,
Q: 'static + FnOnce(Result<isize, Error>) + Send,
&self,
count: isize,
io_priority: Priority,
cancellable: Option<&P>,
callback: Q
) where
P: IsA<Cancellable>,
Q: 'static + FnOnce(Result<isize, Error>) + Send,
pub fn fill_async_future(
&self,
count: isize,
io_priority: Priority
) -> Pin<Box<dyn Future<Output = Result<isize, Error>> + 'static, Global>>
&self,
count: isize,
io_priority: Priority
) -> Pin<Box<dyn Future<Output = Result<isize, Error>> + 'static, Global>>
pub fn get_available(&self) -> usize
pub fn get_buffer_size(&self) -> usize
pub fn peek_buffer(&self) -> Vec<u8, Global>
pub fn read_byte<P>(&self, cancellable: Option<&P>) -> Result<i32, Error> where
P: IsA<Cancellable>,
P: IsA<Cancellable>,
pub fn set_buffer_size(&self, size: usize)
pub fn connect_property_buffer_size_notify<F>(&self, f: F) -> SignalHandlerId where
F: 'static + Fn(&Self),
F: 'static + Fn(&Self),
Implementors
impl<O> BufferedInputStreamExt for O where
O: IsA<BufferedInputStream>,
O: IsA<BufferedInputStream>,
pub fn fill<P>(
&self,
count: isize,
cancellable: Option<&P>
) -> Result<isize, Error> where
P: IsA<Cancellable>,
&self,
count: isize,
cancellable: Option<&P>
) -> Result<isize, Error> where
P: IsA<Cancellable>,
pub fn fill_async<P, Q>(
&self,
count: isize,
io_priority: Priority,
cancellable: Option<&P>,
callback: Q
) where
P: IsA<Cancellable>,
Q: 'static + FnOnce(Result<isize, Error>) + Send,
&self,
count: isize,
io_priority: Priority,
cancellable: Option<&P>,
callback: Q
) where
P: IsA<Cancellable>,
Q: 'static + FnOnce(Result<isize, Error>) + Send,
pub fn fill_async_future(
&self,
count: isize,
io_priority: Priority
) -> Pin<Box<dyn Future<Output = Result<isize, Error>> + 'static, Global>>
&self,
count: isize,
io_priority: Priority
) -> Pin<Box<dyn Future<Output = Result<isize, Error>> + 'static, Global>>
pub fn get_available(&self) -> usize
pub fn get_buffer_size(&self) -> usize
pub fn peek_buffer(&self) -> Vec<u8, Global>
pub fn read_byte<P>(&self, cancellable: Option<&P>) -> Result<i32, Error> where
P: IsA<Cancellable>,
P: IsA<Cancellable>,
pub fn set_buffer_size(&self, size: usize)
pub fn connect_property_buffer_size_notify<F>(&self, f: F) -> SignalHandlerId where
F: 'static + Fn(&O),
F: 'static + Fn(&O),