StreamProcessorConfig class

Configuration for stream processing behavior.

Constructors

StreamProcessorConfig.new({int bufferSize = 100, int maxConcurrency = 10, double backpressureThreshold = 0.8, Duration timeout = const Duration(seconds: 30)})
Creates a new stream processor configuration.
const

Properties

backpressureThreshold double
Threshold for applying backpressure (0.0 to 1.0). When buffer reaches this ratio of bufferSize, backpressure is applied.
final
bufferSize int
Maximum number of items to buffer before applying backpressure.
final
hashCode int
The hash code for this object.
no setterinherited
maxConcurrency int
Maximum number of concurrent operations to allow.
final
runtimeType Type
A representation of the runtime type of the object.
no setterinherited
timeout Duration
Timeout for individual operations.
final

Methods

noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited