Struct StreamLaneService 

pub struct StreamLaneService;

The streaming reply-lane service — one shared handler behind every async.http.response.stream.{n} route (each registered with a single instance, so per-request segment order is preserved end-to-end). It forwards each event into the owning request’s renderer; a missing context (completed, timed out or disconnected) makes late segments no-op drops.

Trait Implementations

impl ComposableFunction for StreamLaneService

fn handle_event<'life0, 'async_trait>( &'life0 self, _headers: HashMap<String, String>, input: EventEnvelope, _instance: usize, ) -> Pin<Box<dyn Future<Output = Result<EventEnvelope, AppError>> + Send + 'async_trait>>

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