enum BodySink {
Chunked(Sender<Result<Frame<Bytes>, Error>>),
Buffered(UnboundedSender<BodyChunk>),
}Expand description
The sink side of the body passed to hyper, used to enqueue chunks.
Variants§
Chunked(Sender<Result<Frame<Bytes>, Error>>)
A Tokio sender used to feed chunks to the network stream.
Buffered(UnboundedSender<BodyChunk>)
A Crossbeam sender used to send chunks to the fetch worker, where they will be buffered in order to ensure they are not streamed them over the network.
Implementations§
Source§impl BodySink
impl BodySink
fn transmit_bytes(&self, bytes: IpcSharedMemory)
fn close(&self)
Auto Trait Implementations§
impl Freeze for BodySink
impl RefUnwindSafe for BodySink
impl Send for BodySink
impl Sync for BodySink
impl Unpin for BodySink
impl UnwindSafe for BodySink
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> MaybeBoxed<Box<T>> for T
impl<T> MaybeBoxed<Box<T>> for T
Source§fn maybe_boxed(self) -> Box<T>
fn maybe_boxed(self) -> Box<T>
Convert
Source§impl<T> MaybeBoxed<T> for T
impl<T> MaybeBoxed<T> for T
Source§fn maybe_boxed(self) -> T
fn maybe_boxed(self) -> T
Convert