dart:async

Класс MultiStreamController<T>

Расширенный контроллер потока, предоставляемый методом Stream.multi.

Работает как обычный асинхронный контроллер, но также позволяет синхронно добавлять события. Как и при любой синхронной доставке событий, отправитель должен быть очень осторожен и не доставлять события в моменты, когда новый слушатель может быть не готов их принять. Обычно это означает, что события следует доставлять синхронно только в ответ на другие асинхронные события, поскольку именно в этот момент может произойти асинхронное событие.

Реализуемые типы

• StreamController<T>

Аннотации

• @Since("2.9")

Конструкторы

MultiStreamController()

Свойства

done → Future

только чтениеунаследовано

Объект Future, который завершается, когда контроллер потока заканчивает отправку событий.

hashCode → int

только чтениеунаследовано

Хеш-код этого объекта.

hasListener → bool

только чтениеунаследовано

Есть ли у Stream подписчик.

isClosed → bool

только чтениеунаследовано

Закрыт ли контроллер потока для добавления новых событий.

isPaused → bool

только чтениеунаследовано

Нужно ли подписке буферизовать события.

onCancel ↔ (FutureOr<void> Function()?)

чтение / записьунаследовано

Функция обратного вызова, вызываемая при отмене потока.

onListen ↔ (void Function()?)

чтение / записьунаследовано

Функция обратного вызова, вызываемая при подписке на поток.

onPause ↔ (void Function()?)

чтение / записьунаследовано

Функция обратного вызова, вызываемая при приостановке потока.

onResume ↔ (void Function()?)

чтение / записьунаследовано

Функция обратного вызова, вызываемая при возобновлении потока.

runtimeType → Type

только чтениеунаследовано

Представление типа объекта во время выполнения.

sink → StreamSink<T>

только чтениеунаследовано

Возвращает представление этого объекта, предоставляющее только интерфейс StreamSink.

stream → Stream<T>

только чтениеунаследовано

Поток, которым управляет этот контроллер.

Методы

add(T event) → void

унаследовано

Отправляет событие данных event.

addError(Object error, [StackTrace? stackTrace]) → void

унаследовано

Отправляет или помещает в очередь событие ошибки.

addErrorSync(Object error, [StackTrace? stackTrace]) → void

Добавляет и доставляет событие ошибки.

addStream(Stream<T> source, {bool? cancelOnError}) → Future

унаследовано

Получает события из source и помещает их в поток этого контроллера.

addSync(T value) → void

Добавляет и доставляет событие.

close() → Future

унаследовано

Закрывает поток.

closeSync() → void

Закрывает контроллер и доставляет событие завершения.

noSuchMethod(Invocation invocation) → dynamic

унаследовано

Вызывается при обращении к несуществующему методу или свойству.

toString() → String

унаследовано

Строковое представление этого объекта.

Операторы

operator ==(Object other) → bool

унаследовано

Оператор равенства.