Struct BoxedSendStream
pub struct BoxedSendStream(/* private fields */);Available on crate features
http-backend and http and std only.Expand description
The SendStream of a BoxedConnection.
Trait Implementations§
§impl SendStream for BoxedSendStream
impl SendStream for BoxedSendStream
type Handle = Arc<dyn StreamHandle>
fn id(&self) -> StreamId
§fn poll_write_chunks(
&mut self,
cx: &mut Context<'_>,
chunks: &mut [Bytes],
reserve: u64,
) -> Poll<Result<(), WriteError>>
fn poll_write_chunks( &mut self, cx: &mut Context<'_>, chunks: &mut [Bytes], reserve: u64, ) -> Poll<Result<(), WriteError>>
Write a prefix of
chunks, consuming what was written.
All accepted bytes must be removed from chunks, including partial chunks, on every
poll. When returning Pending, arrange to wake cx when writing can make progress. Read more§fn try_write_generated(
&mut self,
reserve: u64,
generate: impl FnOnce(usize) -> Bytes,
) -> Result<(), WriteError>
fn try_write_generated( &mut self, reserve: u64, generate: impl FnOnce(usize) -> Bytes, ) -> Result<(), WriteError>
Write the chunk
generate builds for the credit available now (minus reserve, 0 if
unknown), calling it exactly once and atomically: QPACK commits encoder state inside it.§fn finish(&mut self) -> Result<(), ClosedStream>
fn finish(&mut self) -> Result<(), ClosedStream>
Finish this
SendStream§fn reset(&mut self, error_code: VarInt) -> Result<(), ClosedStream>
fn reset(&mut self, error_code: VarInt) -> Result<(), ClosedStream>
Reset this
SendStream with the given error_code§fn set_priority(&self, priority: i32) -> Result<(), ClosedStream>
fn set_priority(&self, priority: i32) -> Result<(), ClosedStream>
Set priority of this stream
§fn stopped(
&self,
) -> impl Future<Output = Result<Option<VarInt>, StoppedError>> + Send + Sync + 'static + use<>
fn stopped( &self, ) -> impl Future<Output = Result<Option<VarInt>, StoppedError>> + Send + Sync + 'static + use<>
Resolves with the peer’s STOP_SENDING code, or
None once all data is acknowledged.fn handle(&self) -> Arc<dyn StreamHandle> ⓘ
§fn boxed_handle(&self) -> Arc<dyn StreamHandle> ⓘ
fn boxed_handle(&self) -> Arc<dyn StreamHandle> ⓘ
Erase the stream handle’s type, reusing an existing shared handle when available.
Auto Trait Implementations§
impl !RefUnwindSafe for BoxedSendStream
impl !UnwindSafe for BoxedSendStream
impl Freeze for BoxedSendStream
impl Send for BoxedSendStream
impl Sync for BoxedSendStream
impl Unpin for BoxedSendStream
impl UnsafeUnpin for BoxedSendStream
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§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 more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a rama_grpc::Request§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§fn and<P, B, E>(self, other: P) -> And<T, P>
fn and<P, B, E>(self, other: P) -> And<T, P>
Create a new
Policy that returns Action::Follow only if self and other return
Action::Follow. Read more