pub async fn simple<'c, INPUT, OUTPUT, CONTEXT, OUTPORT, F, E>(
input: BoxStream<VPacket<INPUT>>,
outputs: &mut OUTPORT,
ctx: &'c CONTEXT,
func: &'static F,
) -> Result<(), E>where
CONTEXT: Clone + ConditionallySendSync,
F: Fn(INPUT, CONTEXT) -> BoxFuture<Result<OUTPUT, E>> + ConditionallySendSync,
OUTPORT: SingleOutput + ConditionallySendSync,
INPUT: DeserializeOwned + Clone + ConditionallySendSync,
OUTPUT: Serialize + ConditionallySendSync,
E: Display + ConditionallySendSync,Expand description
Operation helper for common binary operations that have one output.