diff --git a/src/main/kotlin/org/wfanet/measurement/kingdom/service/system/v1alpha/ComputationsService.kt b/src/main/kotlin/org/wfanet/measurement/kingdom/service/system/v1alpha/ComputationsService.kt index 8092063e59c..73944debe1e 100644 --- a/src/main/kotlin/org/wfanet/measurement/kingdom/service/system/v1alpha/ComputationsService.kt +++ b/src/main/kotlin/org/wfanet/measurement/kingdom/service/system/v1alpha/ComputationsService.kt @@ -210,7 +210,7 @@ class ComputationsService( * Default limit for [org.wfanet.measurement.internal.kingdom.StreamMeasurementsRequest] * messages. */ - const val DEFAULT_STREAMING_LIMIT = 50 + const val DEFAULT_STREAMING_LIMIT = 10 private val STATES_SUBSCRIBED = listOf(