waitForResponseInFlow

suspend fun <FLOW, RESPONSE> FlowCollector<FLOW>.waitForResponseInFlow(timeout: Duration, emitLambda: suspend FlowCollector<FLOW>.((RESPONSE) -> Unit) -> Unit): RESPONSE