realmbuilder_mock_helpers

Function process_request_stream

Source 
pub async fn process_request_stream<S, Event>(
    stream: S::RequestStream,
    sender: Sender<Event>,
)
where
    S: DiscoverableProtocolMarker,
    Event: From<<S::RequestStream as TryStream>::Ok>,
    <S::RequestStream as TryStream>::Ok: Debug,
Expand description

Process requests received in the stream and relay them to the provided sender. Logs incoming requests prefixed with the tag.