[−][src]Struct flv_future_aio::fs::BoundedFileSink
File Sink that tracks how much byte it has written This file will not block write operation. It is up to writer to check if maximum file has size is reached since AsyncWrite return IoError
Methods
impl BoundedFileSink
[src]
pub async fn create<P>(
path: P,
option: BoundedFileOption
) -> Result<Self, Error> where
P: AsRef<Path>,
[src]
path: P,
option: BoundedFileOption
) -> Result<Self, Error> where
P: AsRef<Path>,
pub async fn open_write<P>(
path: P,
option: BoundedFileOption
) -> Result<Self, Error> where
P: AsRef<Path>,
[src]
path: P,
option: BoundedFileOption
) -> Result<Self, Error> where
P: AsRef<Path>,
pub async fn open_append<P>(
path: P,
option: BoundedFileOption
) -> Result<Self, Error> where
P: AsRef<Path>,
[src]
path: P,
option: BoundedFileOption
) -> Result<Self, Error> where
P: AsRef<Path>,
pub fn get_current_len(&self) -> u64
[src]
pub fn can_be_appended(&self, buf_len: u64) -> bool
[src]
check if buf_len can be written
pub fn get_path(&self) -> &Path
[src]
pub fn inner(&self) -> &File
[src]
pub fn mut_inner(&mut self) -> &mut File
[src]
pub fn slice_from(
&self,
position: u64,
len: u64
) -> Result<AsyncFileSlice, IoError>
[src]
&self,
position: u64,
len: u64
) -> Result<AsyncFileSlice, IoError>
Trait Implementations
impl AsyncWrite for BoundedFileSink
[src]
fn poll_write(
self: Pin<&mut Self>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
buf: &[u8]
) -> Poll<Result<usize>>
fn poll_flush(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Result<()>>
[src]
fn poll_close(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Result<()>>
[src]
fn poll_write_vectored(
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
[src]
self: Pin<&mut Self>,
cx: &mut Context,
bufs: &[IoSlice]
) -> Poll<Result<usize, Error>>
impl Unpin for BoundedFileSink
[src]
Auto Trait Implementations
impl !RefUnwindSafe for BoundedFileSink
impl Send for BoundedFileSink
impl Sync for BoundedFileSink
impl !UnwindSafe for BoundedFileSink
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<W> AsyncWriteExt for W where
W: AsyncWrite + ?Sized,
[src]
W: AsyncWrite + ?Sized,
fn flush(&mut self) -> Flush<Self> where
Self: Unpin,
[src]
Self: Unpin,
fn close(&mut self) -> Close<Self> where
Self: Unpin,
[src]
Self: Unpin,
fn write(&'a mut self, buf: &'a [u8]) -> Write<'a, Self> where
Self: Unpin,
[src]
Self: Unpin,
fn write_vectored(
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectored<'a, Self> where
Self: Unpin,
[src]
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectored<'a, Self> where
Self: Unpin,
fn write_all(&'a mut self, buf: &'a [u8]) -> WriteAll<'a, Self> where
Self: Unpin,
[src]
Self: Unpin,
fn into_sink<Item>(self) -> IntoSink<Self, Item> where
Item: AsRef<[u8]>,
[src]
Item: AsRef<[u8]>,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> WriteExt for T where
T: AsyncWrite + ?Sized,
[src]
T: AsyncWrite + ?Sized,
fn write(&'a mut self, buf: &'a [u8]) -> WriteFuture<'a, Self> where
Self: Unpin,
[src]
Self: Unpin,
fn flush(&mut self) -> FlushFuture<Self> where
Self: Unpin,
[src]
Self: Unpin,
fn write_vectored(
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectoredFuture<'a, Self> where
Self: Unpin,
[src]
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectoredFuture<'a, Self> where
Self: Unpin,
fn write_all(&'a mut self, buf: &'a [u8]) -> WriteAllFuture<'a, Self> where
Self: Unpin,
[src]
Self: Unpin,
fn write_fmt(&'a mut self, fmt: Arguments) -> WriteFmtFuture<'a, Self> where
Self: Unpin,
[src]
Self: Unpin,