Struct HttpInboundAdapter 

pub struct HttpInboundAdapter { /* private fields */ }

Implementations

impl HttpInboundAdapter

pub fn id(&self) -> &str

pub fn addr(&self) -> SocketAddr

pub fn base_path(&self) -> &str

pub fn mep(&self) -> Mep

pub fn new( host: impl Into<String>, port: u16, base_path: impl Into<String>, channel: ChannelRef, reply_channel: Option<ChannelRef>, mep: Mep, id: Option<String>, ) -> Self

Direct constructor bypassing the staged DSL builder. Use this when you want to instantiate the adapter programmatically without chaining Adapter::inbound().http()... calls. id is optional; if None, an id of the form http-inbound:<host>:<port> is synthesized (matching the builder’s auto pattern).

pub fn new_in_out( host: impl Into<String>, port: u16, base_path: impl Into<String>, channel: ChannelRef, reply_channel: Option<ChannelRef>, id: Option<String>, ) -> Self

Convenience: construct InOut adapter (request/reply pattern).

pub fn new_in_only_202( host: impl Into<String>, port: u16, base_path: impl Into<String>, channel: ChannelRef, id: Option<String>, ) -> Self

Convenience: construct InOnly202 adapter (fire-and-forget pattern).

impl HttpInboundAdapter

pub fn register_endpoint( &self, method: &str, path: &str, ep: Weak<InMemoryEndpoint>, )

pub fn register_endpoint_any(&self, path: &str, ep: Weak<InMemoryEndpoint>)

pub async fn serve(&self) -> Result<()>

pub async fn run_once(self) -> Result<()>

pub fn spawn_once(self) -> HttpServerHandle

pub fn spawn_serve(self) -> HttpServerHandle

Trait Implementations

impl BaseAdapter for HttpInboundAdapter

fn id(&self) -> &str

Stable identifier for this adapter instance (user-assigned or generated).

impl Clone for HttpInboundAdapter

fn clone(&self) -> HttpInboundAdapter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpInboundAdapter

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

Formats the value using the given formatter.

impl InboundAdapter for HttpInboundAdapter

fn run<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Run the adapter until stopped (lifecycle). Implementations define their own shutdown semantics.