dart:isolate

ReceivePort абстрактный класс

Вместе с SendPort, единственный способ связи между изолятами.

ReceivePort имеет sendPort свойство, которое возвращает SendPort. Любое сообщение, отправленное через этот SendPort, доставляется в ReceivePort, из которого оно было создано. Там сообщение передаётся слушателю ReceivePort.

ReceivePort — это потоковая передача без широковещательной рассылки. Это означает, что он буферизует входящие сообщения до тех пор, пока не будет зарегистрирован слушатель. Только один слушатель может получать сообщения. См. Stream.asBroadcastStream для преобразования порта в широковещательный поток.

ReceivePort может иметь много SendPortов.

Реализует

• Stream

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

ReceivePort()

factory

Открывает долгоживущий порт для получения сообщений.

ReceivePort.fromRawReceivePort(RawReceivePort rawPort)

factory

Создаёт ReceivePort из RawReceivePort.

Свойства

sendPort → SendPort

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

Возвращает SendPort, отправляющий в этот порт получения.

first → Future

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

Возвращает первый элемент потока.

hashCode → int

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

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

isBroadcast → bool

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

Является ли этот поток широковещательным.

isEmpty → Future<bool>

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

Сообщает, содержит ли этот поток какие-либо элементы.

last → Future

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

Возвращает последний элемент потока.

length → Future<int>

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

Подсчитывает элементы в потоке.

runtimeType → Type

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

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

single → Future

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

Возвращает единственный элемент.

Операторы

operator ==(other) → bool

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

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

Методы

close() → void

Закрывает this.

listen(void onData(message), { Function onError, void onDone(), bool cancelOnError }) → StreamSubscription

Унаследовано от Stream.

any(bool test(T element)) → Future<bool>

inherited

Проверяет, принимает ли test любой элемент, предоставляемый этим потоком.

asBroadcastStream({void onListen(StreamSubscription<T> subscription), void onCancel(StreamSubscription<T> subscription) }) → Stream

inherited

Возвращает поток с множественными подписками, который генерирует те же события, что и этот.

asyncExpand<E>(Stream<E> convert(T event)) → Stream<E>

inherited

Создаёт новый поток с событиями потока по исходному событию.

asyncMap<E>(dynamic convert(T event)) → Stream<E>

inherited

Создаёт новый поток, асинхронно отображающий каждое событие данных этого потока в новое событие.

contains(Object needle) → Future<bool>

inherited

Проверяет, встречается ли needle в элементах, предоставляемых этим потоком.

distinct([bool equals(T previous, T next) ]) → Stream

inherited

Пропускает события данных, если они равны предыдущему событию данных.

drain<E>([E futureValue ]) → Future<E>

inherited

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

elementAt(int index) → Future

inherited

Возвращает значение index-го события данных этого потока.

every(bool test(T element)) → Future<bool>

inherited

Проверяет, принимает ли test все элементы, предоставляемые этим потоком.

expand<S>(Iterable<S> convert(T value)) → Stream<S>

inherited

Создаёт новый поток из этого потока, преобразующий каждый элемент в ноль или более событий.

firstWhere(bool test(T element), { Object defaultValue() }) → Future

inherited

Находит первый элемент этого потока, соответствующий test.

fold<S>(S initialValue, S combine(S previous, T element)) → Future<S>

inherited

Сводит последовательность значений, многократно применяя combine.

forEach(void action(T element)) → Future

inherited

Выполняет action для каждого события данных в потоке.

handleError(Function onError, { bool test(error) }) → Stream

inherited

Создаёт обёртку Stream, которая перехватывает некоторые ошибки из этого потока.

join([String separator = "" ]) → Future<String>

inherited

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

lastWhere(bool test(T element), { Object defaultValue() }) → Future

inherited

Находит последний элемент в этом потоке, соответствующий test.

map<S>(S convert(T event)) → Stream<S>

inherited

Создаёт новый поток, преобразующий каждый элемент этого потока в новое значение с помощью функции convert.

noSuchMethod(Invocation invocation) → dynamic

inherited

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

pipe(StreamConsumer streamConsumer) → Future

inherited

Перенаправляет события этого потока в streamConsumer.

reduce(dynamic combine(T previous, T element)) → Future

inherited

Сводит последовательность значений, многократно применяя combine.

singleWhere(bool test(T element)) → Future

inherited

Находит единственный элемент в этом потоке, соответствующий test.

skip(int count) → Stream

inherited

Пропускает первые count событий данных из этого потока.

skipWhile(bool test(T element)) → Stream

inherited

Пропускает события данных из этого потока, пока они соответствуют test.

take(int count) → Stream

inherited

Предоставляет не более первых count событий данных этого потока.

takeWhile(bool test(T element)) → Stream

inherited

Пересылает события данных, пока test успешно.

timeout(Duration timeLimit, { void onTimeout(EventSink<T> sink) }) → Stream

inherited

Создаёт новый поток с теми же событиями, что и этот поток.

toList() → Future<List>

inherited

Собирает данные этого потока в List.

toSet() → Future<Set>

inherited

Собирает данные этого потока в Set.

toString() → String

inherited

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

transform<S>(StreamTransformer<dynamic, S> streamTransformer) → Stream<S>

inherited

Цепочечно использует этот поток как вход для предоставленного StreamTransformer.

where(bool test(T event)) → Stream

inherited

Создаёт новый поток из этого потока, отбрасывая некоторые события данных.