Package io.getstream.android.core.api.processing
See: Description
-
Class Summary Class Description StreamAggregatedEvent A batch of events produced by StreamEventAggregator during a traffic spike. StreamEventAggregationPolicy Complete aggregation configuration for StreamEventAggregator. StreamBatcherKt StreamDebouncerKt StreamEventAggregatorKt StreamRetryProcessorKt StreamSerialProcessingQueueKt StreamSingleFlightProcessorKt StreamThrottlerKt -
Interface Summary Interface Description StreamBatcher Batches a bursty stream of items into batches delivered at controlled intervals. StreamDebouncer Debounces a bursty stream of values so that only the last value is delivered after a quiet period. StreamEventAggregator Adaptive event aggregator that switches between individual and aggregated event delivery based on traffic volume. StreamRetryProcessor Strategy-based retry executor used inside the Stream SDK. StreamSerialProcessingQueue A simple serial execution queue for suspending tasks. StreamSingleFlightProcessor A concurrency construction that implements the single-flight pattern (à la Go's singleflight): concurrent calls with the same keyshare one in-flight execution and all await the same result.StreamThrottler Rate-limits a bursty stream of values so that at most one value is delivered per time window. -
Object Summary Object Description Companion