run

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