SenderStreamController<T> class

Mixed in types
Available Extensions

Constructors

SenderStreamController(OnReomveCallback onRemove, KeyControllerCallback onSend, bool shouldCache)

Properties

activeUnits Set<StreamSubscriptionUnit<T>>
finalinherited
dirtyUnits Set<StreamSubscriptionUnit<T>>
finalinherited
hashCode int
The hash code for this object.
no setterinherited
hasListener bool
no setterinherited
identityKey Object
latefinalinherited
isCanceled bool
no setterinherited
isDisposed bool
no setterinherited
isPaused bool
no setterinherited
lastData ↔ T?
getter/setter pairinherited
listenFirst bool
no setterinherited
messageKey Object?
getter/setter pairinherited
nullOnError bool
getter/setter pairinherited
onRemove ↔ OnReomveCallback
getter/setter pair
onSend KeyControllerCallback
getter/setter pair
pausedUnits Set<StreamSubscriptionUnit<T>>
finalinherited
runtimeType Type
A representation of the runtime type of the object.
no setterinherited
serverName String?
getter/setter pairinherited
shouldCache bool
final
stream SenderLayzeStream<T>
no setterinherited
streamAsync SenderLayzeStream<T>
no setterinherited

Methods

add(T data) → void
inherited
addData(dynamic data) → void
inherited
addError(Object error, StackTrace stackTrace) → void
inherited
cancel() → void
inherited
close() → void
inherited
dispose() → void
没有监听者调用一次
inherited
listen(void onData(T event)?, {Function? onError, void onDone()?, bool? cancelOnError, bool async = false}) StreamSubscription<T>
inherited
moveToDirty() → void
inherited
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
notifyClient() → void
inherited
onListen(StreamSubscriptionUnit<T> child) → void
inherited
resetDispose() → void
inherited
toString() String
A string representation of this object.
inherited
trigger({StreamSubscriptionUnit<T>? self}) → void
如果isPaused状态没有改变,resume时有可能发生这种情况 手动为self更新数据
inherited

Operators

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