AcpOutboundHub<T> class
final
A bounded one-to-many outbound hub.
Before a subscriber exists, the hub retains at most capacity values. That replay is consumed by the first subscription only. Every live subscriber then owns an independent bounded queue while its Dart subscription is paused. Queue overflow drops the oldest value and reports once per overflow episode until the subscriber resumes and drains.
Constructors
- AcpOutboundHub({int capacity = 1024, AcpOutboundOverflowHandler? onOverflow})
- Creates a bounded hub.
Properties
- capacity → int
-
Maximum replay and per-subscriber paused values.
final
- hashCode → int
-
The hash code for this object.
no setterinherited
- isClosed → bool
-
Whether close has been called.
no setter
- onOverflow → AcpOutboundOverflowHandler?
-
Optional overflow diagnostic callback.
final
- replayLength → int
-
Number of values waiting for the first subscriber.
no setter
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
- subscriberCount → int
-
Current number of live subscriber streams.
no setter
Methods
-
add(
T value) → void -
Sends
valueto all current subscribers or the initial replay buffer. -
close(
) → Future< void> - Closes every subscriber and discards queued values.
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
subscribe(
) → AcpOutboundSubscription< T> - Creates an independent live subscription.
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited