run

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