Module source_consumer 

WasmSourceConsumer — Consumer trait implementation for the source world.

The guest IS the source: it owns an async run() loop that awaits host-provided accept-http / submit-exchange. The host bridges the async guest to the pipeline via bounded tokio channels, and uses the cancel token (raced in each import) + epoch deadline for cancellation.

Structs

WasmSourceConsumer

Consumer backed by a WASM source world component.

Functions

parse_guest_config

Extract guest config (bind, path, etc.) from URI query params. WasmConfig::from_uri drops unknown params, so we parse them separately.