Вопросы по теме 'system.reactive'
Как Reactive Framework (Rx) соотносится с задачами в .NET 4?
В наши дни асинхронное и параллельное программирование должно быть у всех на уме, и .NET 4 добавляет ряд улучшений, таких как встроенные потокобезопасные коллекции и, конечно же, задачи. Вдобавок к этому я начал изучать Reactive Framework (Rx)....
1203 просмотров
schedule
11.02.2023
Примеры Reactive Framework для .NET, доказывающие его полезность
Вокруг новой версии Reactive Framework в .NET 4.0. Хотя я думаю, что понял его основную концепцию, я не полностью уверен, что он настолько полезен. Можете ли вы привести хороший пример (наполовину простой для понимания), который полностью...
1640 просмотров
schedule
25.05.2023
Почему ParallelQuery‹T›.Where не работает при преобразовании в Observable?
У меня есть наблюдаемая коллекция, которую я хочу обрабатывать параллельно, затем наблюдать за обработанными значениями при фильтрации и, наконец, подписывать обработчик, который получает отфильтрованные значения.
Мой образец синтаксически верен и...
1808 просмотров
schedule
15.06.2022
Сжатие Rx IObservable с бесконечным набором чисел
У меня есть IObservable [именованные строки в приведенном ниже примере] из среды расширений Reactive, и я хочу добавить номера индексов к каждому объекту, который он наблюдает.
Я попытался реализовать это с помощью функции Zip:...
274 просмотров
schedule
26.09.2023
Создание наблюдаемого перетаскивания мышью с помощью Reactive Extensions
У меня есть следующие
var leftMouseDown = Observable.FromEvent<MouseButtonEventArgs>(displayCanvas, "MouseLeftButtonDown");
var leftMouseUp = Observable.FromEvent<MouseButtonEventArgs>(displayCanvas, "MouseLeftButtonUp");
var mouseMove...
2323 просмотров
schedule
17.05.2023
Модульное тестирование с помощью FromAsyncPattern
У Reactive Extensions есть небольшая ловушка для упрощения вызова асинхронных методов:
var func = Observable.FromAsyncPattern<InType, OutType>(
myWcfService.BeginDoStuff,
myWcfService.EndDoStuff);...
1641 просмотров
schedule
24.04.2024
Убийственное преимущество реактивных расширений?
В чем главное преимущество реактивных расширений (для .NET или JavaScript)? Зачем разработчику изучать и использовать их?
2175 просмотров
schedule
10.11.2022
Реактивные расширения: Throttle/Sample с различным интервалом
У меня есть IObservable , который выдает значения через случайные промежутки времени, и я хочу ограничить эту последовательность. Одна вещь, которую я обнаружил, заключается в том, что определение «дросселирования» оператором Throttle не совпадает...
3475 просмотров
schedule
24.06.2022
Использование реактивного расширения для определенных последовательностей нажатия клавиш?
Я новичок ... или, точнее ... никогда не использовал RX, поэтому мне было интересно, могу ли я использовать его в этой ситуации: я хочу добавить в свое приложение своего рода функцию живых шаблонов Resharper, которая позволяет пользователям вводить...
759 просмотров
schedule
11.11.2022
Есть ли способ узнать, когда был обработан OnNext?
У меня есть настройка конвейера, использующая реактивные расширения, начиная с потока значений (могут поступить в любое время, когда захотят), а затем, подписавшись на него, есть много разных «модулей», выводящих поток вычисляемых значений, и этот...
305 просмотров
schedule
06.04.2023
В чем разница между паттернами наблюдатель и субъект-наблюдатель
Во время просмотра некоторых видеороликов на канале 9 о реактивных расширениях для .NET кто-то спросил, является ли библиотека реактивных расширений реализацией шаблона Observer. Далее ведущий ответил, что библиотека является реализацией шаблона...
514 просмотров
schedule
19.11.2022
Rx: EnumerableEx.For() против Enumerable.SelectMany()
System.Interactive.dll включает метод For() со следующей реализацией:
IEnumerable<TResult> For<TSource, TResult>(
IEnumerable<TSource> source,
Func<TSource, IEnumerable<TResult>> resultSelector)
{
return...
1324 просмотров
schedule
22.11.2022
Существуют ли какие-либо соглашения по генерации исключений из реализаций IObserver?
Я реализую IObserver.
Существуют ли какие-либо соглашения об исключении из IObserver?
Может ли OnNext или любой другой метод моей реализации вызывать исключения?
Что должно произойти, если в OnNext или OnCompleted выдается исключение -...
98 просмотров
schedule
10.09.2022
Модульное тестирование для события с использованием Reactive Extensions
Я использую Reactive Extensions для .NET (Rx) для отображения событий как IObservable<T> . Я хочу создать модульный тест, в котором я утверждаю, что конкретное событие запущено. Вот упрощенная версия класса, который я хочу протестировать:...
11388 просмотров
schedule
21.08.2022
Проблемы с агрегатором событий с использованием реактивных расширений
Чтобы связать мое приложение MEF , я использую агрегатор событий здесь . Это было идеально для распределения данных по модулям, которые действительно в них нуждаются.
Я все больше увлекаюсь использованием реактивных расширений и пытаюсь сделать...
1025 просмотров
schedule
09.04.2023
Объединить большое количество наблюдаемых в новые наблюдаемые
У меня есть, скажем, 1000 наблюдаемых. Теперь я хочу объединить все события в новую наблюдаемую, которая запускает OnNext, как только все остальные отправят событие. Как лучше всего это сделать с помощью Rx?
Обновление : несколько отличных...
972 просмотров
schedule
23.02.2023
Для чего на самом деле возвращается действие, возвращаемое параметром подписки IObservable.Create?
Определение метода IObservable.Create:
public static IObservable<TSource> Create<TSource>(
Func<IObserver<TSource>, Action> subscribe
)
Я понимаю, что функция вызывается после подписки на наблюдаемое, где я могу...
179 просмотров
schedule
08.06.2022
Использование Rx для блокировки (и, возможно, тайм-аута) в асинхронной операции
Я пытаюсь переписать некоторый код, используя Reactive Extensions для .NET, но мне нужно некоторое руководство о том, как достичь моей цели.
У меня есть класс, который инкапсулирует некоторое асинхронное поведение в низкоуровневой библиотеке....
5996 просмотров
schedule
05.09.2023
Почему Rx Observable.Subscribe блокирует мой поток?
Привет! Я попробовал один из примеров 101 Rx:
static IEnumerable<int> GenerateAlternatingFastAndSlowEvents()
{
int i = 0;
while (true)
{
if (i > 1000)
{
yield...
4060 просмотров
schedule
24.11.2023
Реактивные расширения, обновляющие пользовательский интерфейс
Я делаю этот асинхронный веб-запрос несколько раз (может быть дважды, трижды или даже 6 раз в зависимости от условий)
var request = HttpWebRequest.CreateHttp(url);
var observableRequest =...
1116 просмотров
schedule
13.07.2023
