Описание тега asyncstream
AsyncStream — это тип параллелизма Swift, представляющий собой асинхронную последовательность, сгенерированную из замыкания, которое вызывает продолжение для создания новых элементов.
2
ответа
TaskGroup ограничивает объем используемой памяти для большого количества задач
Я пытаюсь создать механизм загрузки фрагментированных файлов, используя современный Swift Concurrency. Существует потоковое средство чтения файлов, которое я использую для чтения файлов по частям размером 1 МБ. Имеет два закрытия nextChunk: (DataChu…
20 май '22 в 10:20
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…
27 окт '22 в 17:25
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…
28 июн '23 в 01:19