Struct AsyncSecureChannel 

pub struct AsyncSecureChannel<T> { /* private fields */ }

High-level async facade that combines Session, FoctetFramed, and TLV helpers.

This wrapper is intended for async runtimes where callers want:

• automatic session-aware control/rekey handling
• application-data TLV framing by default
• an async send/receive application-data API

Implementations

impl<T> AsyncSecureChannel<T>

pub fn with_app_stream_id(self, stream_id: u32) -> Self

Sets the default stream ID for application-data frames.

pub fn with_app_flags(self, flags: u8) -> Self

Sets the default plaintext frame flags for application-data frames.

pub fn session(&self) -> &Session

Returns immutable reference to the underlying Session.

pub fn session_mut(&mut self) -> &mut Session

Returns mutable reference to the underlying Session.

pub fn framed_ref(&self) -> &FoctetFramed<T>

Returns immutable reference to inner framed transport.

pub fn framed_mut(&mut self) -> &mut FoctetFramed<T>

Returns mutable reference to inner framed transport.

pub fn into_parts(self) -> (FoctetFramed<T>, Session)

Consumes the wrapper and returns (framed, session).

impl<T: PollIo + Unpin> AsyncSecureChannel<T>

pub fn from_active_session(io: T, session: Session) -> Result<Self, CoreError>

Constructs an async secure channel from an active session.

The session must already be in Active state with derived traffic keys.

pub async fn send_data(&mut self, plaintext: &[u8]) -> Result<(), CoreError>

Sends application data in an APPLICATION_DATA TLV with session-aware rekey handling.

pub async fn send_tlvs(&mut self, tlvs: &[Tlv]) -> Result<(), CoreError>

Sends explicit TLVs with session-aware rekey handling.

This bypasses APPLICATION_DATA convenience framing.

pub async fn recv_application(&mut self) -> Result<Vec<u8>, CoreError>

Receives the next application-data payload.

Control frames are handled automatically. The method loops internally until it receives a non-control frame, then decodes TLVs and returns the first APPLICATION_DATA value.

pub async fn recv_tlvs(&mut self) -> Result<Vec<Tlv>, CoreError>

Receives the next non-control frame and returns decoded TLVs.

impl<T> AsyncSecureChannel<TokioIo<T>>

where T: AsyncRead + AsyncWrite + Unpin,

pub fn from_tokio(io: T, session: Session) -> Result<Self, CoreError>

Constructs async secure channel from a Tokio I/O object and an active session.

impl<T> AsyncSecureChannel<FuturesIo<T>>

where T: AsyncRead + AsyncWrite + Unpin,

pub fn from_futures(io: T, session: Session) -> Result<Self, CoreError>

Constructs async secure channel from a futures-io object and an active session.

Trait Implementations

impl<T: Debug> Debug for AsyncSecureChannel<T>

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

Formats the value using the given formatter.