pub struct SendStream(/* private fields */);
Expand description
Send part of the client stream
Implementations§
Source§impl SendStream
impl SendStream
pub fn stream(&self) -> &StreamRef
Sourcepub fn available_send_capacity(&self) -> WindowSize
pub fn available_send_capacity(&self) -> WindowSize
Get available capacity
Sourcepub async fn send_capacity(&self) -> Result<WindowSize, OperationError>
pub async fn send_capacity(&self) -> Result<WindowSize, OperationError>
Wait for available capacity
Sourcepub async fn send_payload(
&self,
res: Bytes,
eof: bool,
) -> Result<(), OperationError>
pub async fn send_payload( &self, res: Bytes, eof: bool, ) -> Result<(), OperationError>
Send payload
Sourcepub fn send_trailers(&self, map: HeaderMap)
pub fn send_trailers(&self, map: HeaderMap)
Send trailers
Sourcepub fn disconnect_on_drop(&self)
pub fn disconnect_on_drop(&self)
Disconnect connection on stream drop
Sourcepub fn poll_send_capacity(
&self,
cx: &Context<'_>,
) -> Poll<Result<WindowSize, OperationError>>
pub fn poll_send_capacity( &self, cx: &Context<'_>, ) -> Poll<Result<WindowSize, OperationError>>
Check for available send capacity
Sourcepub fn poll_send_reset(
&self,
cx: &Context<'_>,
) -> Poll<Result<(), OperationError>>
pub fn poll_send_reset( &self, cx: &Context<'_>, ) -> Poll<Result<(), OperationError>>
Check if send part of stream get reset
Trait Implementations§
Source§impl Debug for SendStream
impl Debug for SendStream
Auto Trait Implementations§
impl Freeze for SendStream
impl !RefUnwindSafe for SendStream
impl !Send for SendStream
impl !Sync for SendStream
impl Unpin for SendStream
impl !UnwindSafe for SendStream
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