dart:async

Класс StreamSink<S>

Объект, принимающий события потока как синхронно, так и асинхронно.

Класс StreamSink объединяет методы из StreamConsumer и EventSink.

Методы EventSink нельзя использовать во время вызова addStream. Как только Future из addStream завершается со значением, методы EventSink можно использовать снова.

Если addStream вызывается после любого из методов EventSink, он будет отложен до тех пор, пока внутренняя система не обработает данные, добавленные методами EventSink.

Когда используются методы EventSink, можно использовать done Future для обработки любых ошибок.

При вызове close возвращается done Future.

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

• EventSink<S>
• StreamConsumer<S>

Реализующие типы

• IOSink
• StreamController
• WebSocket

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

StreamSink()

Свойства

done → Future

только для чтения

Возвращает будущее, которое завершается, когда StreamSink завершен.

hashCode → int

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

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

runtimeType → Type

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

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

Методы

add(S event) → void

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

Добавляет данные event в канал.

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

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

Добавляет error в канал.

addStream(Stream<S> stream) → Future

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

Обрабатывает элементы stream.

close() → Future

переопределено

Уведомляет канал о том, что больше потоков добавляться не будет.

noSuchMethod(Invocation invocation) → dynamic

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

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

toString() → String

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

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

Операторы

operator ==(Object other) → bool

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

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