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