Лучшие system.reactive вопросы ИТ разработчиков

  • 3 голосов
  • 3 ответа
  • 0 просмотров
3 ответа

Stream Multicasting - один раз считайте поток, но обрабатывайте его по-разному, с минимальной буферизацией

Для масштабируемости и экономии ресурсов лучше избегать считывания всего входного потока в память, а вместо этого пытаться обрабатывать его как поток, считывая небольшие порции за раз. Это легко сделать в .NET, когда у вас есть одна вещь, которую ...

Задан 15 Jan 2014, 17:05 от Daniel Schilling
  • 6 голосов
  • 1 ответ
  • 0 просмотров
1 ответ

В Rx, как группировать события по идентификатору и регулировать каждую группу по нескольким временным интервалам?

Я получил, так сказать, веселье Rx, и этот вопрос связан с моимВот а такжеВот, Тем не менее, может быть, это кому-то поможет, так как я мог бы рассматривать ...

Задан 17 Oct 2013, 14:44 от Veksi
  • 20 голосов
  • 5 ответов
  • 0 просмотров
5 ответов

Руководство по System.Reactive.Joins

Я ищу введение / некоторую документацию System.Reactive.Joins, которая включает классы Pattern, Plan, QueryablePattern и QueryablePlan. Google ничего не показывает («System.Reactive.Joins»), в MSDN ничего нет, примеров ...

Задан 07 Mar 2012, 05:05 от Matthew Finlay
  • 7 голосов
  • 2 ответа
  • 0 просмотров
2 ответа

Ричард пропустил критическое предположение, что ваша функция StartWork имеет подпись «IObservable <SomeResult> StartWork (элемент QueueItem)» - перегрузка слияния, которую вы ищете, работает только с IObservable <IObservable <T >>

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

Задан 30 Jun 2011, 16:55 от Jeff
  • 1 голос
  • 0 ответов
  • 0 просмотров
0 ответов

 путь?

я есть очередь блокировки, которая продолжает получать сообщения через какое-то приложение, теперь в приложении asp.net я пытался использовать очередь и записать вывод в файл CSV / JSON. Здесь я хочу хранить сообщения размером до 1 МБ, которые ...

Задан 08 Jan 2019, 06:46 от user584018
  • 4 голосов
  • 4 ответа
  • 0 просмотров
4 ответа

Наблюдаемый от Цепных Задач

Я пытаюсь создать Observable, где каждый элемент создается с помощью асинхронной задачи. Следующий элемент должен быть произведен посредством асинхронного вы...

Задан 17 Jul 2015, 22:12 от csauve
  • 2 голосов
  • 4 ответа
  • 0 просмотров
4 ответа

Запускайте методы параллельно, используя Reactive

Halo там все, я искал решение с RX framework. Мой класс C # 4.0 будет вызывать 2 разных метода, и чтобы сэкономить время, я хочу сделать это параллельно. Ест...

Задан 04 Mar 2013, 13:09 от Chakkara S
  • 19 голосов
  • 1 ответ
  • 0 просмотров
1 ответ

Предварительный исторический поток и прямой эфир в Rx

У меня есть горячая наблюдаемая, которую я обычно реализую, используя обычныйSubject внизу, чтобы заинтересованные могли подписаться на прямой поток уведомлений. Теперь я хотел бы сохранить этот живой поток, но также показать исторический поток ...

Задан 07 Jan 2014, 10:56 от Cel
  • 1 голос
  • 2 ответа
  • 0 просмотров
2 ответа

@Greg Bray - снова удален переключатель, так как он не будет работать для последующих окон, так как подписка будет завершена при закрытии первого окна

ал с Reactive Extensions (RX) в Windows Phone 7 и очень близок к рабочему решению, но поймал одну маленькую деталь. Я пытаюсь обработать необработанные сенсорные события, ...

Задан 28 Jan 2011, 07:43 от Greg Bray
  • 7 голосов
  • 1 ответ
  • 0 просмотров
1 ответ

Мраморные диаграммы [закрыто]

Мраморные диаграммы часто из команды Rx объясняют, как работают определенные операторы в Rx. Есть ли инструмент для создания мраморных диаграмм?

Задан 07 Oct 2013, 18:19 от Santin
  • 1 голос
  • 2 ответа
  • 0 просмотров
2 ответа

Буферизуйте данные из курсора базы данных, сохраняя интерфейс

У меня есть каталог базы данных, который заполнен, и курсор, который можно использовать для извлечения объектов. Этот каталог, очевидно, может быть очень большим, и я хотел бы использоватьReactiveUIбуферизировать данные, сохраняя привязанность ...

Задан 15 Nov 2013, 21:13 от Charlie
  • 6 голосов
  • 1 ответ
  • 0 просмотров
1 ответ

В Rx, как группировать события по идентификатору и регулировать каждую группу по нескольким временным интервалам?

Я получил, так сказать, веселье Rx, и этот вопрос связан с моимВот [https://stackoverflow.com/questions/19425965/rx-how-to-group-by-a-key-a-complex-object-and-later-do-selectmany-without-stopp] а ...

Задан 17 Oct 2013, 16:44 от Veksi
  • 63 голосов
  • 2 ответа
  • 0 просмотров
2 ответа

Как Reactive Framework, PLINQ, TPL и Parallel Extensions связаны друг с другом?

По крайней мере, с момента выпуска .NET 4.0 Microsoft, похоже, приложила много усилий для поддержки параллельного и асинхронного программирования, и, похоже,...

Задан 26 Jan 2010, 08:08 от bitbonk
  • 0 голосов
  • 1 ответ
  • 0 просмотров
1 ответ

Как организовать последовательность обработки данных с помощью .net RX

Каков наилучший способ организовать последовательность процессоров данных с .net RX? - а. Вызовите методы на наблюдаемых, какobservable.Do(log).Select(transformation).Do(work).Aggregate(someState)... - б. Реализация пользовательских наблюдателей, ...

Задан 09 Nov 2012, 15:26 от arena-ru
  • 11 голосов
  • 5 ответов
  • 0 просмотров
5 ответов

Что определенно не является хвостовой рекурсивностью. Я думаю, что если вы можете сделать его хвост рекурсивным, то это, вероятно, решит вашу проблему

аюсь придумать Rx Builder для использования Reactive Extension в синтаксисе выражения вычисления F #. Как я могу это исправить, чтобы он не взорвал стек? Как пример Seq ниже. И есть ли планы предоставить реализацию RxBuilder как часть Reactive ...

Задан 28 May 2011, 14:44 от Holoed
  • 94 голосов
  • 5 ответов
  • 0 просмотров
5 ответов

Почему темы не рекомендуются в .NET Reactive Extensions?

В настоящее время я знакомлюсь с платформой Reactive Extensions для .NET и прорабатываю различные вводные ресурсы, которые я нашел (главным образом, http://www.introtorx.com [http://www.introtorx.com]) Наше приложение включает в себя несколько ...

Задан 18 Jan 2013, 10:01 от Anthony
  • 3 голосов
  • 3 ответа
  • 0 просмотров
3 ответа

Каков хороший способ запуска периодических задач в c # с использованием Rx с одним ограничением одновременного выполнения?

Я хочу запускать периодические задачи с ограничением, что в каждый момент времени может выполняться не более одного выполнения метода.Я экспериментировал с R...

Задан 14 Jul 2015, 06:18 от smartnut007
  • 7 голосов
  • 5 ответов
  • 0 просмотров
5 ответов

RX Observable.TakeWhile проверяет условие ДО каждого элемента, но мне нужно выполнить проверку после

Observable.TakeWhile позволяет запускать последовательность при условии, что условие истинно (с использованием делегата, чтобы мы могли выполнять вычисления ...

Задан 04 Feb 2013, 22:29 от NoPyGod
  • 8 голосов
  • 1 ответ
  • 0 просмотров
1 ответ

NewThreadScheduler.Default планирует все работы в одном потоке

В настоящее время я пытаюсь обернуть голову вокруг параллелизма с RX .NET и чего-то путаюсь. Я хочу запустить четыре относительно медленные задачи параллельн...

Задан 21 Jul 2013, 10:30 от Anders Arpi
  • 6 голосов
  • 2 ответа
  • 0 просмотров
2 ответа

Добавление наблюдаемой последовательности после подписки

Мы используем Rx для мониторинга активности в нашем приложении silverlight, чтобы мы могли отображать сообщение пользователю после периода бездействия. Мы превращаем события (движения мыши и т. Д.) В наблюдаемые, а затем объединяем наблюдаемые ...

Задан 10 Nov 2011, 17:00 от user1040208
  • 8 голосов
  • 1 ответ
  • 0 просмотров
1 ответ

NewThreadScheduler.Default планирует все работы в одном потоке

В настоящее время я пытаюсь сосредоточиться на параллелизме с RX .NET и что-то путаюсь. Я хочу запустить четыре относительно медленные задачи параллельно, поэтому я предположил,NewThreadScheduler.Default будет путь, как это«Представляет объект, ...

Задан 21 Jul 2013, 12:30 от Anders Arpi
  • 2 голосов
  • 2 ответа
  • 0 просмотров
2 ответа

 тег: -J

ndows Phone 7 появилась новая версияBufferWithTimeOrCountметод расширения для IObservable, который возвращает «поток потоков» вместо предыдущего «потока списков». У меня возникают трудности при попытке использовать новые или старые методы, ...

Задан 30 Jan 2011, 07:00 от Greg Bray
  • 1 голос
  • 2 ответа
  • 0 просмотров
2 ответа

Проблема с кэшированием в WebClient / HttpClient

Я разрабатываю код для опроса биржи Bitstamp каждые 30 секунд. Это код, который я имею: public IObservable<string> Stream(Uri way, WebClient wc) { Func<IObserver<string>, Task> Fun = async Observer => { var res = ...

Задан 22 Dec 2013, 12:45 от Anton
  • 8 голосов
  • 1 ответ
  • 0 просмотров
1 ответ

@ Jmix90 оригинальный вопрос обновлен с моим кодом. Обратная связь приветствуется.

ного новичок в Rx.NET. Можно ли поймать исключение, которое может быть выдано любым из подписчиков? Возьми следующее ... handler.FooStream.Subscribe( _ => throw new Exception("Bar"), _ => { });В настоящее время я ловлю на основе подписки с ...

Задан 26 Aug 2011, 20:10 от drstevens
  • 12 голосов
  • 2 ответа
  • 0 просмотров
2 ответа

Как мне ожидать ответа от субъекта RX без введения условия гонки?

У меня есть служба, которая позволяет вызывающей стороне отправлять команды и получать ответы асинхронно. В реальном приложении эти действия довольно отключе...

Задан 27 Jun 2014, 18:02 от Danny Tuppeny
  • 8 голосов
  • 1 ответ
  • 0 просмотров
1 ответ

Как вернуть IObservable из Web API

У меня есть простой веб-API, который возвращает Iobservable. Я использую HttpClient, чтобы получить Observable, чтобы я мог подписаться на него. Моя проблема...

Задан 26 Nov 2013, 23:07 от saipanyam
  • 33 голосов
  • 9 ответов
  • 0 просмотров
9 ответов

С Rx, как я игнорирую значение «все, кроме самого последнего», когда мой метод подписки работает

С помощьюРеактивные расширенияЯ хочу игнорировать сообщения, поступающие из моего потока событий, которые происходят, пока мой

Задан 17 Apr 2013, 12:13 от Wilka
  • 7 голосов
  • 4 ответа
  • 0 просмотров
4 ответа

Оберните наблюдателя файла в реактивные расширения

я смотрел на упаковку наблюдателя файла в заметное, чтобы помочь в обработке событий, но яУ меня возникли проблемы с поиском того, как добиться от меня желае...

Задан 04 Jan 2013, 13:29 от stimms
  • 13 голосов
  • 2 ответа
  • 0 просмотров
2 ответа

Какой ответ? Выглядит иначе для меня.

аю на RX и совершенно сбит с толку тем, для чего предназначен Планировщик? Может кто-нибудь объяснить?

Задан 18 Feb 2011, 20:43 от Andy
  • 5 голосов
  • 2 ответа
  • 0 просмотров
2 ответа

Как я могу поделиться наблюдаемой с публикацией и подключением?

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

Задан 27 Aug 2015, 22:17 от Whymarrh
  • 1 голос
  • 3 ответа
  • 0 просмотров
3 ответа

Создание нескольких таймеров с реактивными расширениями

У меня очень простой класс, который я использую для опроса каталога на наличие новых файлов. Это&#39;У него есть местоположение, время начала мониторинга это...

Задан 07 Aug 2013, 23:26 от Scott Baker
Page 1 of 3
1 2 3