Описание тега asyncstream

AsyncStream — это тип параллелизма Swift, представляющий собой асинхронную последовательность, сгенерированную из замыкания, которое вызывает продолжение для создания новых элементов.
2 ответа

TaskGroup ограничивает объем используемой памяти для большого количества задач

Я пытаюсь создать механизм загрузки фрагментированных файлов, используя современный Swift Concurrency. Существует потоковое средство чтения файлов, которое я использую для чтения файлов по частям размером 1 МБ. Имеет два закрытия nextChunk: (DataChu…
2 ответа

Проблемы с циклом сохранения с использованием AsyncStream в задаче

Обнаружил эту проблему при работе с новыми инструментами параллелизма Swift. Вот настройка: class FailedDeinit { init() { print(#function, id) task = Task { await subscribe() } } deinit { print(#function, id) } func subscribe() async { let stream = …
09 июн '22 в 13:40
0 ответов

Два асинхронных потока, один внутри другого

У меня есть два асинхронных потока. ПервыйPathMonitorClientэто просто потокиNWPath.Status. Второй - этоdatabaseClientкоторый публикует мои изменения базы данных. Я хочу загружать изменения моей базы данных только тогда, когда NWPath.Status == .satis…
06 окт '22 в 13:50
0 ответов

публикация значения NSObject по KeyPath с использованием AsyncStream - проблема эталонного цикла

Я использую параллелизм функций Swift. Я создал вспомогательную функцию, которая возвращает AsyncStream со значениями, опубликованными реализациями NSOBject. Вид кода ниже. func asyncStreamFor<Root: NSObject, Value> (_ root: Root, keyPath: Key…
1 ответ

Просмотр спама AsyncStream, где AsyncPublisher не

Я сталкиваюсь с поведением с AsyncStream, которое я не совсем понимаю. Когда у меня есть актер с опубликованной переменной, я могу «подписаться» на него через AsyncPublisher, и он ведет себя так, как ожидалось, обновляясь только при изменении значен…
26 сен '22 в 22:56
0 ответов

AsyncStream не выполняет закрытие

поэтому я читаю книгу Modern Concurrency с сайта raywenderlich.com и предполагаю, что книга устарела или что-то в этом роде, я пытаюсь запуститьclosureвнутриAsyncStreamно, похоже, этого не происходит, я все еще новичок в этом Async/Await, но при доб…
02 фев '23 в 03:10
0 ответов

Используйте NWPathMonitor с Swift Modern Concurrency (AsyncStream) и GCD (DispatchQueue)

Я заметил, чтоstart(queue:)для метода требуется очередь типаDispatchQueue. Есть ли способ реализовать это с помощью Swift Modern Concurrency, возможно, с помощью ? Использование документации Apple дляAsyncStream, я создал расширение для , но не могу…
27 окт '22 в 11:33
1 ответ

Как использовать AsyncThrowingStream Swift с прослушивателями Firestore

Как я могу преобразовать этот код для использования AsyncThrowingStream? private var listenerRegistration: ListenerRegistration? func unsubscribe() { if listenerRegistration != nil { listenerRegistration?.remove() listenerRegistration = nil } } func…