dart:async

Класс MultiStreamController<T>

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

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

Реализованные типы

• StreamController<T>

Аннотации

• @Since("2.9")

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

MultiStreamController()

Свойства

done → 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

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

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