Struct ArcRwLockStream 

pub struct ArcRwLockStream(/* private fields */);

Thread-safe TCP stream wrapper.

Provides shared access to a TcpStream using Arc and RwLock.

Fields

• Arc<RwLock<TcpStream>> - The protected TCP stream.

Implementations

impl ArcRwLockStream

pub fn from(arc_rw_lock_stream: Arc<RwLock<TcpStream>>) -> ArcRwLockStream

Creates a new ArcRwLockStream from an Arc<RwLock>.

Arguments

• Arc<RwLock<TcpStream>> - The stream to wrap.

Returns

• ArcRwLockStream - The new stream wrapper.

pub fn from_stream(stream: TcpStream) -> ArcRwLockStream

Creates a new ArcRwLockStream from a TcpStream.

Wraps the stream in an Arc<RwLock<_>>.

Arguments

• TcpStream - The raw stream to wrap.

Returns

• ArcRwLockStream - The new thread-safe stream wrapper.

pub async fn read(&self) -> RwLockReadGuard<'_, TcpStream>

Gets a read lock on the inner TcpStream.

Allows shared read access to the stream.

Returns

• RwLockReadGuardTcpStream - The read guard for the stream.

pub async fn try_send<D>(&self, data: D) -> Result<(), ResponseError>

where D: AsRef<[u8]>,

Sends HTTP response data over the stream.

Arguments

• AsRef<[u8]> - The response data to send (must implement AsRef<u8>).

Returns

• Result<(), ResponseError> - Result indicating success or failure.

pub async fn send<D>(&self, data: D)

where D: AsRef<[u8]>,

Sends HTTP response data over the stream.

Arguments

• AsRef<[u8]> - The response data to send (must implement AsRef<u8>).

Panics

Panics if the write operation fails.

pub async fn try_send_body<D>(&self, data: D) -> Result<(), ResponseError>

where D: AsRef<[u8]>,

Sends HTTP response body.

Arguments

• AsRef<[u8]> - The response body data (must implement AsRef<u8>).

Returns

• Result<(), ResponseError> - Result indicating success or failure.

pub async fn send_body<D>(&self, data: D)

where D: AsRef<[u8]>,

Sends HTTP response body.

Arguments

• AsRef<[u8]> - The response body data (must implement AsRef<u8>).

Panics

Panics if the write operation fails.

pub async fn try_send_body_list<I, D>( &self, data_iter: I, ) -> Result<(), ResponseError>

where I: IntoIterator<Item = D>, D: AsRef<[u8]>,

Sends multiple HTTP response bodies sequentially.

Arguments

• I: IntoIterator<Item = D>, D: AsRef<[u8]> - The response body data list to send.

Returns

• Result<(), ResponseError> - Result indicating success or failure.

pub async fn send_body_list<I, D>(&self, data_iter: I)

where I: IntoIterator<Item = D>, D: AsRef<[u8]>,

Sends multiple HTTP response bodies sequentially.

Arguments

• I: IntoIterator<Item = D>, D: AsRef<[u8]> - The response body data list to send.

Panics

Panics if any write operation fails.

pub async fn try_flush(&self) -> Result<(), ResponseError>

Flushes all buffered data to the stream.

Returns

• Result<(), ResponseError> - Result indicating success or failure.

pub async fn flush(&self)

Flushes all buffered data to the stream.

Panics

Panics if the flush operation fails.

Trait Implementations

impl Clone for ArcRwLockStream

fn clone(&self) -> ArcRwLockStream

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ArcRwLockStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl From<&ArcRwLockStream> for Context

Implementation of From trait for converting &ArcRwLockStream into Context.

fn from(stream: &ArcRwLockStream) -> Self

Converts a reference to a network stream into a Context with default request.

Arguments

• &ArcRwLockStream - The network stream reference to convert.

Returns

• Context - The newly created context instance.

impl From<ArcRwLockStream> for Context

Implementation of From trait for converting ArcRwLockStream into Context.

fn from(stream: ArcRwLockStream) -> Self

Converts a network stream into a Context with default request.

Arguments

• ArcRwLockStream - The network stream to convert.

Returns

• Context - The newly created context instance.