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

Описание тега Вопросы с тегом
Реактивные расширения поверх потоков Dart.
0 ответов

Поведение Subject StreamTransformer

Я ищу способ превратить обычный поток в BehaviorSubject. Это код, который я сделал, но я не знаю, как указать, что мой класс возвращает BehaviorSubject. И мой преобразователь выдает ошибку времени выполнения (слушание вызвано на ноль). import 'dart:…
18 ноя '18 в 13:25
1 ответ

Плохое состояние: вы не можете закрыть тему, пока элементы добавляются из addStream во флаттере

Я использую RxDart, чтобы наблюдать за изменениями и соответственно обновлять пользовательский интерфейс. Когда приложение запускается, я звоню по сети и успешно получаю данные, наблюдаю за изменениями и соответствующим образом обновляю пользователь…
05 сен '18 в 18:31
0 ответов

StreamBuilder InitialData и управление потоком

Вот BLoc, который имеет мой BehaviorSubject и геттеры для потока и последнего значения потока. Stream<User> get currentUser => _currentUserSubject.stream; User get currentUserValue => _currentUserSubject.stream.value; final _currentUserS…
03 дек '18 в 12:26
1 ответ

Обратный вызов Stream.last никогда не срабатывает

Я пишу свое приложение Flutter с шаблоном BLoC. И то, что я хочу, довольно просто: показать TextField с последним значением из потока в качестве начального значения. Есть простой блок: class MyBloc { BehaviorSubject<String> _titleController; S…
19 дек '18 в 08:03
0 ответов

Поддерживает ли RxDart противодавление?

Когда есть быстрый производитель и медленный потребитель, я хочу заменить все старые ожидающие выбросы на новейшие - что-то похожее на Emitter.BackpressureMode.LATEST RxJava. Есть ли способ добиться этого в RxDart или Dart Streams?
10 янв '19 в 12:57
1 ответ

Насколько дорогие потоки?

Во Flutter у меня есть вид с ползунком, содержащим сетку из многих текстовых полей. Я планирую присоединить каждое текстовое поле к своему собственному потоку (с помощью построителя потоков), в результате чего несколько сотен потоков будут работать …
12 янв '19 в 12:58
1 ответ

Как установить currentIndex в BottomNavigationBar в флаттер из BLOC?

Я хотел бы использовать StatelessWidget с BottomNavigationBar, которым я бы управлял из BLOC. Я могу подключить корпус Scaffold и onTap BottomNavigationBar к BLOC (см. Код). Но я не понимаю, как можно установить currentIndex BottomNavigationBar из B…
15 янв '19 в 13:52
1 ответ

Как показать другой виджет, когда пользователь находится в автономном режиме при использовании StreamBuilder?

Я пытаюсь получить некоторые данные из Интернета. С использованием FutureBuilder, обработка для различных случаев, таких как офлайн, онлайн, ошибка довольно легко, но я использую StreamBuilder и я не могу понять, как обращаться с делом в автономном …
19 янв '19 в 15:19
0 ответов

С помощью RxDart генерировать несколько выходных событий для одного события при выполнении длинного списка асинхронных задач

Я хотел бы сделать что-то очень простое, но я очень новичок в мире Rx и у меня есть некоторые проблемы с переводом моей логики в код. Процесс такой: пользователь имеет некоторый код и вводит его в приложение,вызывается Bloc.postCode(код) этот код ис…
21 янв '19 в 18:27
0 ответов

Поток (BLoC) не выдает значения при использовании в TabBarView

Я создаю TabBarView, и потомки этого вида создаются с использованием шаблона BLoC. Когда я использую основной поток в BLoC, я получил пустой результат на вкладках. Однако, когда я переключаю поток на BehaviorSubject, я получаю ожидаемый результат - …
30 янв '19 в 18:19
0 ответов

rxdart с несколькими слушателями, вызывающими многократный запуск обратного вызова сканирования для одного потока

У меня есть вопрос о rxdart и конкретно об ожидаемом поведении здесь. Я подписываюсь с 2 слушателями на Observable. С одним слушателем обратный вызов сканирования запускается один раз. С другим слушателем он запускается дважды. Мне кажется неправиль…
01 фев '19 в 18:38
0 ответов

TimeoutException в тесте с использованием BehaviorSubject - BLoC

Я создал простой блок, который использует BehaviorSubject и я пытаюсь проверить его излучаемые значения, но я продолжаю получать TimeoutException во время теста или ошибки в порядке, когда я поменяю местами добавленные потоки. Блок class Application…
23 фев '19 в 04:53
1 ответ

Flutter Auth (шаблон BLoC и rxDart)

Я хотел сделать приложения с авторизацией на партнере BLoC, но я столкнулся с ошибкой: The following NoSuchMethodError was thrown building AuhtScreen(dirty, state: _AuhtScreenState<dynamic>#00539): The getter 'blocState' was called on null. Re…
26 фев '19 в 10:00
1 ответ

Два разных блока вызывают "Плохое состояние: поток уже прослушан".

Я новичок, чтобы трепетать. У меня есть виджет (и блок) и регистрация (и блок) на том же Scaffold: @override Widget build(BuildContext context) { _init(context); return Scaffold( resizeToAvoidBottomPadding: false, body: SingleChildScrollView( child:…
01 мар '19 в 05:53
0 ответов

Flutter - rxdart - чтение потока несколько раз

У меня есть простое приложение, которое 2 вкладки, я пытаюсь вам блок шаблонов для перемещения данных. Поток 1: 1. Запускается приложение, создается блок с засеянным значением 2. Для страницы запускается метод сборки и отображаются данные. 3. Пользо…
01 мар '19 в 12:55
1 ответ

Как получить StreamSubscription от StreamBuilder

При добавлении слушателя в RxDart PublishSubject Я получаю StreamSubscription, Я могу затем использовать StreamSubscription приостановить и возобновить, есть ли способ сделать это с StreamBuilder?
14 фев '19 в 22:07
1 ответ

Как условно добавить ошибку в Observable в RxDart?

Используя Dart StreamTransformer, я могу оценить значение потока и выбрать его выдачу в зависимости от некоторых условий (например, sink.add(value)) или добавьте ошибку (например, sink.addError('Enter a valid number')). Как мне лучше всего сделать э…
13 дек '18 в 08:55
0 ответов

Стрим против магазинов

Я использую магазины из плагина Flutter Flux в своем приложении и теперь должен переключиться на шаблон BLOC. Просматривая различные учебные пособия и блоги, везде, где я видел использование потоков (RxDart), и ни один из них никогда не использовал …
21 ноя '18 в 15:58
1 ответ

Dart / rxdart / Bloc: получить элемент события с оригинальным типом при прослушивании потока BehaviorSubject

Рассмотрим этот код (не обращайте внимания на бесполезный listen метод, это просто показать вариант использования): class Bloc { final BehaviorSubject notifPrompt = BehaviorSubject<NotifPromptModel>()..add(NotifPromptModel(answered: false)); v…
11 ноя '18 в 03:52
1 ответ

Дарт: конвертировать Observable в Future и наоборот?

Как я могу конвертировать дротик Observable к Future и наоборот?
20 ноя '18 в 13:54