Skip to main content

paired_right_stream

wick_component::binary

Function paired_right_stream 

Source 
pub async fn paired_right_stream<'c, LEFT, RIGHT, OUTPUT, CONTEXT, OUTPORT, F, E>(
    left: BoxStream<VPacket<LEFT>>,
    right: BoxStream<VPacket<RIGHT>>,
    outputs: &mut OUTPORT,
    ctx: &'c CONTEXT,
    func: &'static F,
) -> Result<(), E>
where
    CONTEXT: Clone + ConditionallySendSync,
    F: Fn(LEFT, WickStream<RIGHT>, CONTEXT) -> BoxFuture<Result<OUTPUT, E>> + ConditionallySendSync,
    OUTPORT: SingleOutput + ConditionallySendSync,
    LEFT: DeserializeOwned + Clone + ConditionallySendSync,
    RIGHT: DeserializeOwned + Clone + ConditionallySendSync,
    OUTPUT: Serialize + ConditionallySendSync,
    E: Display + ConditionallySendSync,
Expand description

Operation helper for common for binary operations that pair single packets with potential streams of packets.