CountFlushPolicy class

Flushes after count events have been observed since the last flush.

Inheritance

Constructors

CountFlushPolicy(int count)
Creates a policy that flushes every count events (minimum 1).

Properties

count → int
Number of events between flushes.
final
hashCode → int
The hash code for this object.
no setterinherited
onFlushRequested ↔ void Function()?
Set by the delivery engine so a policy can wake it the moment a flush is due. Not intended to be assigned by policy implementations.
getter/setter pairinherited
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited
shouldFlush ↔ bool
When true, the engine should flush pending deliveries.
getter/setter pairinherited

Methods

noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
onEvent(LiquidMessage message) → void
Called for every message accepted into the delivery path (including batch-mode enqueues).
override
reset() → void
Called after a flush so the policy can restart its counters/timers.
override
start() → void
Called once when the policy is attached to a running client.
inherited
stop() → void
Called when the client is disposed.
inherited
toString() → String
A string representation of this object.
inherited

Operators

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