Вопросы по теме 'system.reactive'

Создание клиентского API REST с использованием реактивных расширений (Rx)
Я пытаюсь понять правильные варианты использования Reactive Extensions (Rx). Примеры, которые продолжают появляться, — это события пользовательского интерфейса (перетаскивание, рисование) и предположения о том, что Rx подходит для асинхронных...
6271 просмотров
schedule 29.11.2023

Можно ли запускать код Silverlight, используя среду выполнения полной платформы .NET?
Чтобы интегрироваться с текущей системой для непрерывной интеграции, мы хотим использовать NUnit для тестирования (не UI) кода Silverlight. Это означает выполнение кода Silverlight с использованием среды выполнения полной платформы .NET, которая...
116 просмотров

Как получить последнее значение от ReplaySubject‹T› перед завершением
Мне нужен способ получить самый последний элемент, добавленный в ReplaySubject, который соответствует определенным критериям. Пример кода ниже делает то, что мне нужно, но он не кажется правильным подходом: static void Main(string[] args) {...
4146 просмотров
schedule 12.07.2022

Нужно ли использовать IObservable для отслеживания изменений в моей коллекции?
Прочитал немного об IObservable, и мне интересно, что шаблон даст мне (если что-нибудь) в моем сценарии. У меня есть приложение WPF с сеткой данных, сетка привязана к коллекции IObservable продукта. ProductList.DataContext =...
689 просмотров
schedule 26.02.2024

Как создать IObservable‹T›, который читает из очереди сообщений MSMQ?
Я удаляю нашу систему электронной почты с нашего сайта ASP.NET, который раньше отправлял электронные письма немедленно с помощью системы для обработки запросов в отдельной службе, чтобы снизить нагрузку на веб-сайт. Я пытаюсь спроектировать его на...
1527 просмотров
schedule 14.04.2024

Ошибка Не удается преобразовать лямбда-выражение при подписке на IObservable‹Point›
я пытаюсь реализовать стандартное перетаскивание изображения в wpf, используя Rx. var mouseDown = from evt in Observable.FromEventPattern<MouseButtonEventArgs>(image, "MouseLeftButtonDown") select...
8733 просмотров
schedule 09.04.2024

Выберите «Многие» в Rx
Пожалуйста, дайте мне знать, как работает оператор SelectMany в Rx. Я тоже не знаю больше об этом операторе в Linq. Пожалуйста, объясните это на простом примере, а также в каком случае мы будем использовать этот оператор в Rx.
9787 просмотров
schedule 04.05.2024

Сцепить несколько двухэтапных загрузок файлов с помощью Rx
Я пытаюсь загрузить несколько файлов из клиента Silverlight непосредственно в Amazon S3. Пользователь выбирает файлы из стандартного диалогового окна открытия файлов, и я хочу связать загрузки, чтобы они происходили последовательно по одному за раз....
389 просмотров
schedule 06.05.2024

Реактивные расширения (rx) используют только ОДИН фоновый поток
Я использую расширения rx для простой реализации, и все работает нормально. Я использую планировщик потоков. Это тоже отлично работает, но я хочу иметь только один фоновый поток! Идея состоит в том, что у меня есть один поток пользовательского...
755 просмотров
schedule 11.07.2022

LINQ с расширениями RX
У меня сложилось впечатление, что язык запросов LINQ работает для IObservable так же, как и для IEnumerable с ReactiveExtensions. У меня есть следующий код Public Sub Foo(source As IObservable(Of Tuple(Of Integer, Integer))) Dim filtered =...
135 просмотров
schedule 15.01.2024

Реактивные расширения, которые использует субъект
Я нахожусь на ранних этапах изучения Rx и наткнулся на класс Subject. Я не совсем понимаю, почему этот класс существует. Я понимаю, что он реализует как IObservable, так и IObserver, но для чего используются субъекты? Насколько я могу судить, они...
649 просмотров
schedule 28.10.2022

Как Rx относится к реактивному программированию?
Я читал об основной идее реактивного программирования, заключающейся в том, что переменные изменяются со временем в зависимости от выражения их исходного значения. Я даже реализовал это с помощью выражений. Но потом я смотрю на Microsoft Reactive...
867 просмотров

Каковы планировщики по умолчанию для каждого наблюдаемого оператора?
На этой странице в MSDN указано, что Если вы не используете перегрузку, которая принимает планировщик в качестве аргумента, Rx выберет планировщик по умолчанию, используя принцип наименьшего параллелизма. Это означает, что выбирается...
5697 просмотров
schedule 14.11.2022

Ошибка неоднозначной ссылки IObservable
Я использую реактивные расширения в своем приложении WPF. И при его использовании я получаю ниже неоднозначную ошибку ссылки. The type 'System.IObservable<T>' exists in both 'mscorlib.dll' and 'System.Reactive.dll' Я также пробовал с...
2079 просмотров
schedule 23.10.2022

Дизайн RX — дросселирование обращений к внешним системам
Я пишу брокер сообщений, который подключается к IBM MQ и папкам в файловой системе. После сбора сообщений он затем материализует их в строго типизированные классы и подключает их к RX Subjects. Я повысил осведомленность о сообщениях, которые...
93 просмотров
schedule 12.03.2024

Ссылка на предыдущие элементы. Есть ли какое-либо наблюдаемое расширение для этого в Rx или Rxx?
У меня есть IObservable, я ищу способ сделать что-то подобное var referenceBack2 = source.Ref(2); скажем, у меня есть эта последовательность в источнике A-B-C-D-E-F-G-H ReferenceBack2 не будет выполнять OnNext() для A до тех пор, пока B...
60 просмотров
schedule 17.11.2023

Использование времени ожидания Rx с наблюдателем FromEventPattern
Я пытаюсь реализовать тайм-аут, когда за период времени нет событий. Сценарий: У меня есть объект, который вызывает событие каждый раз при получении сообщения. Я хотел бы реагировать, когда нет сообщений (событий OnReceived), полученных в...
1188 просмотров
schedule 10.10.2022

Эквивалент ReactiveCocoa для Observable.Create
Я хотел бы создать собственный RACSignal, но предпочел бы не создавать целый класс. Я просто хочу указать блок для вызова, когда наблюдатели подписываются. В .Net Rx я бы сделал так: return Observable.Create(observer => { ... //...
194 просмотров

Предметы Forward Rx с кулдауном, переключение на выборку, когда они приходят слишком быстро
Я ищу метод Rx, который возьмет наблюдаемое и поместит последний элемент в «перезарядку», чтобы, когда предметы поступают медленнее, чем время перезарядки, они просто перенаправлялись, но когда они поступают быстрее, вы просто получить последнее...
735 просмотров
schedule 24.12.2023

Время жизни 'Linqed' IObservable с использованием реактивных выражений
Это потенциально очень глупый вопрос, но я не уверен, что мне следует держаться за IObservables, сгенерированные методами расширения Linq. Большинство примеров, кажется, делают это по умолчанию, но что произойдет в долго работающей программе. У меня...
103 просмотров
schedule 30.12.2023