pub struct StreamRef(/* private fields */);
Implementations§
source§impl StreamRef
impl StreamRef
pub fn id(&self) -> StreamId
sourcepub fn empty_capacity(&self) -> Capacity
pub fn empty_capacity(&self) -> Capacity
Get capacity instance for current stream
sourcepub fn send_response(
&self,
status: StatusCode,
headers: HeaderMap,
eof: bool
) -> Result<(), OperationError>
pub fn send_response( &self, status: StatusCode, headers: HeaderMap, eof: bool ) -> Result<(), OperationError>
Send stream response
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 client trailers and close stream
pub fn available_send_capacity(&self) -> WindowSize
pub async fn send_capacity(&self) -> Result<WindowSize, OperationError>
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§
Auto Trait Implementations§
impl Freeze for StreamRef
impl !RefUnwindSafe for StreamRef
impl !Send for StreamRef
impl !Sync for StreamRef
impl Unpin for StreamRef
impl !UnwindSafe for StreamRef
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