WebSocketAckableServer class
- Inheritance
-
- Implemented types
-
Methods
-
add(AckableClient value)
→ bool
-
Adds
value to the set.
inherited
-
addAll(Iterable<AckableClient> elements)
→ void
-
Adds all
elements to this set.
inherited
-
any(bool test(AckableClient element))
→ bool
-
Checks whether any element of this iterable satisfies
test.
inherited
-
broadcaster<T>({FutureOr<void> onCancel()?})
→ StreamController<T>
-
Creates a StreamController.broadcast that is closed within
dispose.
inherited
-
cancelBind(Symbol key)
→ Future<bool>
-
inherited
-
cancelBindings()
→ Future<void>
-
Cancel all active listeners, timers and close the controllers.
This does not dispose other disposables bound with
bind.
inherited
-
cancelTimer(Symbol key)
→ bool
-
inherited
-
cancelUnique(Symbol id)
→ Future<void>
-
inherited
-
cancelUniques(Set<Symbol> ids)
→ Future<void>
-
inherited
-
cast<T>()
→ DelegatingSet<T>
-
A view of this iterable as an iterable of
R instances.
inherited
-
checkHeart()
→ FutureOr<bool>
-
inherited
-
clear()
→ void
-
Removes all elements from the set.
inherited
-
contains(Object? element)
→ bool
-
Whether the collection contains an element equal to
element.
inherited
-
containsAll(Iterable<Object?> other)
→ bool
-
Whether this set contains all the elements of
other.
inherited
-
controller<T>({bool broadcast = false, FutureOr<void> onCancel()?})
→ StreamController<T>
-
Creates a StreamController that is closed within
dispose.
inherited
-
difference(Set<Object?> other)
→ Set<AckableClient>
-
Creates a new set with the elements of this that are not in
other.
inherited
-
disposable(Disposable disposable)
→ void
-
Binds another
Disposable object to be disposed when this
is disposed.
inherited
-
dispose()
→ Future<void>
-
Cancel all active listeners, timers, close the controllers
and disposes other disposables bound with
bind.
inherited
-
each<T>(Stream<T> stream, void fn(T item), {Symbol? uniqueId})
→ StreamSubscription<T>
-
Listens and iterates through
stream by calling fn.
The listener is disposed in the dispose function.
inherited
-
elementAt(int index)
→ AckableClient
-
Returns the
indexth element.
inherited
-
every(bool test(AckableClient element))
→ bool
-
Checks whether every element of this iterable satisfies
test.
inherited
-
expand<T>(Iterable<T> f(AckableClient element))
→ Iterable<T>
-
Expands each element of this Iterable into zero or more elements.
inherited
-
firstWhere(bool test(AckableClient element), {AckableClient orElse()?})
→ AckableClient
-
The first element that satisfies the given predicate
test.
inherited
-
fold<T>(T initialValue, T combine(T previousValue, AckableClient element))
→ T
-
Reduces a collection to a single value by iteratively combining each
element of the collection with an existing value
inherited
-
followedBy(Iterable<AckableClient> other)
→ Iterable<AckableClient>
-
Creates the lazy concatenation of this iterable and
other.
inherited
-
forEach(void f(AckableClient element))
→ void
-
Invokes
action on each element of this iterable in iteration order.
inherited
-
intersection(Set<Object?> other)
→ Set<AckableClient>
-
Creates a new set which is the intersection between this set and
other.
inherited
-
interval(Duration duration, dynamic fn(Timer), {Symbol? uniqueId, bool execNow = true})
→ Timer
-
inherited
-
join([String separator = ''])
→ String
-
Converts each element to a String and concatenates the strings.
inherited
-
lastWhere(bool test(AckableClient element), {AckableClient orElse()?})
→ AckableClient
-
The last element that satisfies the given predicate
test.
inherited
-
lookup(Object? object)
→ AckableClient?
-
If an object equal to
object is in the set, return it.
inherited
-
makeClient(WebSocketChannel wsc)
→ FutureOr<WebSocketAckableClient>
-
override
-
makeRoom(String name)
→ FutureOr<AckableRoom<WebSocketAckableClient>>
-
override
-
map<T>(T f(AckableClient e))
→ Iterable<T>
-
The current elements of this iterable modified by
toElement.
inherited
-
noSuchMethod(Invocation invocation)
→ dynamic
-
Invoked when a nonexistent method or property is accessed.
inherited
-
periodic(Duration duration, dynamic fn(Timer), {Symbol? uniqueId})
→ Timer
-
Creates a periodic Timer.periodic that gets cancelled within
dispose.
inherited
-
reduce(AckableClient combine(AckableClient value, AckableClient element))
→ AckableClient
-
Reduces a collection to a single value by iteratively combining elements
of the collection using the provided function.
inherited
-
remove(Object? value)
→ bool
-
Removes
value from the set.
inherited
-
removeAll(Iterable<Object?> elements)
→ void
-
Removes each element of
elements from this set.
inherited
-
removeWhere(bool test(AckableClient element))
→ void
-
Removes all elements of this set that satisfy
test.
inherited
-
retainAll(Iterable<Object?> elements)
→ void
-
Removes all elements of this set that are not elements in
elements.
inherited
-
retainWhere(bool test(AckableClient element))
→ void
-
Removes all elements of this set that fail to satisfy
test.
inherited
-
reusable()
→ Disposable
-
inherited
-
room(String name)
→ Future<AckableRoom<AckableClient>?>
-
inherited
-
shout(String subject, Object? data, {})
→ void
-
inherited
-
singleWhere(bool test(AckableClient element), {AckableClient orElse()?})
→ AckableClient
-
The single element that satisfies
test.
inherited
-
skip(int n)
→ Iterable<AckableClient>
-
Creates an Iterable that provides all but the first
count elements.
inherited
-
skipWhile(bool test(AckableClient value))
→ Iterable<AckableClient>
-
Creates an
Iterable that skips leading elements while test is satisfied.
inherited
-
start()
→ Future<HttpServer>
-
Starts the websocket server.
inherited
-
streamedInterval<T, E>(Stream<T> valueStream, Duration duration, dynamic fn(T?), {Symbol? uniqueId})
→ StreamedIntervalTimer
-
inherited
-
take(int n)
→ Iterable<AckableClient>
-
Creates a lazy iterable of the
count first elements of this iterable.
inherited
-
takeFirst<T>(Stream<T> stream)
→ Future<T>
-
inherited
-
takeWhile(bool test(AckableClient value))
→ Iterable<AckableClient>
-
Creates a lazy iterable of the leading elements satisfying
test.
inherited
-
talk(String subject, Object? data, {Future onAck(AckableClient, AckedMessage)?, })
→ Future<void>
-
inherited
-
timer(Duration duration, dynamic fn())
→ Timer
-
Creates a Timer that gets cancelled within
dispose if not executed.
inherited
-
toList({bool growable = true})
→ List<AckableClient>
-
Creates a List containing the elements of this Iterable.
inherited
-
toSet()
→ Set<AckableClient>
-
Creates a Set containing the same elements as this iterable.
inherited
-
toString()
→ String
-
A string representation of this object.
inherited
-
union(Set<AckableClient> other)
→ Set<AckableClient>
-
Creates a new set which contains all the elements of this set and
other.
inherited
-
uniqueEach<T>(Symbol id, Stream<T> stream, void fn(T item))
→ StreamSubscription<T>
-
Listens and iterates through
stream by calling fn.
The listener is disposed in the dispose function.
inherited
-
uniqueListen(Symbol id, ChangeNotifier obj, void fn())
→ void
-
Listens and iterates through
obj.addListener by calling fn.
The listener is disposed in the dispose function.
inherited
-
uniqueTimer(Symbol uniqueId, Duration duration, dynamic fn())
→ Timer
-
Creates a Timer that gets cancelled within
dispose if not executed.
inherited
-
where(bool test(AckableClient element))
→ Iterable<AckableClient>
-
Creates a new lazy Iterable with all elements that satisfy the
predicate
test.
inherited
-
whereType<T>()
→ Iterable<T>
-
Creates a new lazy Iterable with all elements that have type
T.
inherited
