run

suspend fun run(payload: REQUEST, stream: Flow<CLIENT_STREAM>): Flow<SERVER_STREAM>