Я хочу лучше понять код Rx, используя его диаграмму UML. Затем я использую сообщество VS2013 для его создания. Но это не удалось. Диалог происходит с предложением "коллекции были изменены; операция перечисления не может быть выполнена". Какова...

Нужно: долгоиграющая программа с TCP соединениями Программа C# 4.0 (VS1010, XP) должна подключаться к хосту с использованием TCP, отправлять и получать байты, иногда правильно закрывать соединение и открывать его позже. Окружающий код написан в...

Уже есть хороший вопрос об опросе базы данных с использованием Reactive ( опрос базы данных с помощью Reactive Extensions ) У меня аналогичный вопрос, но с изюминкой: мне нужно передать значение из предыдущего результата в следующий запрос. В...

В RxJS есть функция switchMap . Есть ли аналог в ReactiveX/Rx.NET ? Я не вижу его в документации по преобразованию .

У меня есть код, который передает данные из SQL и записывает их в другое хранилище. Код примерно такой: using (var cmd = new SqlCommand("select * from MyTable", connection)) { using (var reader = await cmd.ExecuteReaderAsync()) {...

Итак, у меня есть объект, который содержит наблюдаемое как свойство: public class Tile { ... private BehaviorSubject<TileType> _type; public IObservable<TileType> TypeChanged { get { return...

У меня есть следующий сценарий: переменное количество (более трех) очередей (зависит от конфигурации, установленной в файле) некоторые из этих очередей могут быть либо заполнены данными, либо нет (это зависит от производителя, который получает...

Я пытаюсь протестировать код rx.net, и я совершенно не понимаю, как это сделать. Пример с этого веб-сайта был очень полезен, но я не могу чтобы связать последнюю часть. Ниже приведен пример кода: class SomeClass { constructor(IScheduler...

Я пытаюсь перечислить большой IEnumerable один раз и наблюдайте за перечислением с различными присоединенными операторами ( Count , Sum , Average и т. д.). Очевидный способ — преобразовать его в IObservable с помощью метода ToObservable ,...

Недавно я столкнулся с ситуацией, когда было бы выгодно иметь асинхронную операцию, представленную как Task<T> , так и IObservable<T> . Представление задачи поддерживает состояние операции ( IsCompleted , IsFaulted и т. д.), в то...