Resultados da pesquisa a pedido "system.reactive"
Problema de armazenamento em cache no WebClient / HttpClient
Estou desenvolvendo um código para pesquisar um ticker de troca Bitstamp a cada 30 segundos. Este é um código que tenho: public IObservable<string> Stream(Uri way, WebClient wc) { Func<IObserver<string>, Task> Fun = async Observer => { var res = ...
Transmissão histórica avançada e transmissão ao vivo em Rx
Eu tenho um observável quente que eu normalmente implemento usando um normalSubject embaixo, para que os interessados possam assinar um fluxo de notificações ao vivo. Agora eu gostaria de manter a transmissão ao vivo, mas também expor ...
RX Scheduler - O que é isso?
Estou lendo sobre RX e totalmente enganado para o que o Scheduler se destina? Alguém pode explicar?
EventBus / PubSub vs (extensões reativas) RX com relação à clareza do código em um único aplicativo encadeado
Atualmente, estou usando um EventBus /PubSub [http://en.wikipedia.org/wiki/Publish%E2%80%93subscribe_pattern]arquitetura / padrão com Scala (e JavaFX) para implementar um aplicativo de organização de notas simples (como um cliente do Evernote com ...
Como "reconstruir linhas" de dados lidos no SerialPort usando Rx
Estou apenas aprendendo Rx e estava tentando implementar um "leitor de frases NMEA" de um dispositivo GPS usando SerialPort. O fato de serem dados de GPS é de menor importância para a questão, então vamos esclarecer que o formato NMEA consiste em ...
Por que o retorno de chamada OnError nunca é chamado ao lançar do assinante fornecido?
Por favor, observe o seguinte teste de unidade: using System; using System.Reactive.Linq; using System.Threading; using System.Threading.Tasks; using Microsoft.VisualStudio.TestTools.UnitTesting; namespace UnitTests { [TestClass] public class ...
Qual é a diferença prática entre todas essas extensões observáveis reativas?
Dado um objeto BehaviorS, qual é a diferença prática entre chamar todas essas funções diferentes? Primeiro()Último()LatestValue ()MostRecentValue ()NextValue ()Solteiro()Pegue (1)Supondo que eu entendi direito, todos deveriam fazer a mesma ...
Como aguardo uma resposta de um sujeito do RX sem introduzir uma condição de corrida?
Eu tenho um serviço que permite que um chamador envie comandos e receba respostas de forma assíncrona. Em um aplicativo real, essas ações são bastante desconectadas (algumas ações enviarão um comando e as respostas serão processadas ...
IObservable deve ter preferência sobre eventos ao expor notificações em uma biblioteca direcionada ao .NET 4+
Eu tenho uma biblioteca .NET que, como parte de um Modelo de Objeto, emitirá notificações de determinadas ocorrências. Parece-me que os principaisprofissionais doeventossão acessíveis para iniciantes (e simplicidade em certos contextos de ...
Extensões reativas Inscrever-se aguardando chamada
Quero realizar uma chamada assíncrona com base em cadaevento criado por um Observable Extensions Reativo. Também estou tentando manter tudo sincronizado, pois quero que a chamada assíncrona termine antes que o próximo evento seja tratado. Como ...