Класс StreamSink< S>
Объект, принимающий события потока синхронно и асинхронно.
StreamSink объединяет методы StreamConsumer и EventSink.
Методы EventSink нельзя использовать во время вызова addStream. Как только Future, возвращённый методом addStream, завершится со значением, методы EventSink снова можно будет использовать.
Если addStream вызывается после любого из методов EventSink, его выполнение будет отложено, пока нижележащая система не обработает данные, добавленные методами EventSink.
При использовании методов EventSink для перехвата ошибок можно использовать Future done.
При вызове close будет возвращён Future done.
- Реализуемые типы
-
-
EventSink<
S> -
StreamConsumer<
S>
-
EventSink<
- Реализующие классы
Конструкторы
- StreamSink()
Свойства
- done → Future только для чтения
- Возвращает 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 унаследовано - Оператор равенства.
© 2012 the Dart project authors
Licensed under the BSD 3-Clause "New" or "Revised" License.
https://api.dart.dev/stable/2.19.6/dart-async/StreamSink-class.html