Struct SourceChannels 

pub struct SourceChannels {
    pub request_tx: Sender<(HttpMeta, Receiver<Result<Bytes, CamelError>>)>,
    pub request_rx: Arc<Mutex<Receiver<(HttpMeta, Receiver<Result<Bytes, CamelError>>)>>>,
    pub exchange_tx: Sender<(Exchange, Sender<SubmitOutcome>)>,
    pub exchange_rx: Receiver<(Exchange, Sender<SubmitOutcome>)>,
}

Paired channel endpoints for bridging the guest to async host tasks.

Created once per source consumer instance. The *_tx halves go to the HTTP listener and pipeline bridge tasks; request_rx lives in SourceHostState inside the wasmtime Store, wrapped in an Arc<tokio::sync::Mutex<…>> so the async host import (which receives only &Accessor, not &mut self) can lock().await it to call recv().await.

The request channel carries (HttpMeta, body_rx) — metadata plus a per-request bounded channel streaming body chunks. The body is never materialized as a single Vec<u8>, removing the old 10 MiB cap.

Fields

request_tx: Sender<(HttpMeta, Receiver<Result<Bytes, CamelError>>)>

request_rx: Arc<Mutex<Receiver<(HttpMeta, Receiver<Result<Bytes, CamelError>>)>>>

exchange_tx: Sender<(Exchange, Sender<SubmitOutcome>)>

exchange_rx: Receiver<(Exchange, Sender<SubmitOutcome>)>

Implementations

impl SourceChannels

pub fn new() -> Self

Create a new set of channels with the documented capacities.

Trait Implementations

impl Default for SourceChannels

fn default() -> Self

Returns the “default value” for a type.