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: ArcRwLock<TcpStream>) -> Self

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) -> Self

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

Formats the value using the given formatter.

impl PartialEq for ArcRwLockStream

Implementation of PartialEq trait for ArcRwLockStream.

fn eq(&self, other: &Self) -> bool

Compares two ArcRwLockStream instances for equality.

Arguments

• &self - The first ArcRwLockStream instance.
• other - The second ArcRwLockStream instance to compare.

Returns

• bool - true if the instances point to the same Arc, false otherwise.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ArcRwLockStream

Implementation of Eq trait for ArcRwLockStream.