Resultados da pesquisa a pedido "system.reactive"
Como organizar a sequência de processadores de dados com o .net RX
Qual é a melhor maneira de organizar a sequência de processadores de dados com o .net RX?- uma. Chame métodos em observáveis como
Como ler arquivos intercalados simultaneamente usando extensões reativas
Eu sou novo para as extensões reativas e gostaria de usá-lo (em c #) para ler um arquivo que contém vários fluxos que são intercalados. Basicamente, o arquiv...
C # .NET Rx - Onde está System.Reactive?
Eu tenho uma experiência intensiva em Java, então me perdoe se estiver ignorando algo óbvio em C #, mas minha pesquisa não está me levando a lugar algum. Estou tentando usar a biblioteca Rx .NET reativa. O compilador não está ...
Rx for .NET - O que aconteceu com o Scheduler.Dispatcher?
Estou tentando trabalhar no curso de treinamento de Dan Sullivan Rx Extensions no PluralSight. É uma coisa excelente, mas infelizmente o Rx parece já ter sido alterado, embora o curso tenha sido publicado apenas um mês atrás. maioria das ...
Pausa e Reiniciar assinatura no IObservable frio
Using Rx [http://msdn.microsoft.com/en-us/library/hh212048%28v=VS.103%29.aspx], Desejo pausar e retomar a funcionalidade no seguinte código: Como implementar Pause () e Resume ()? static IDisposable _subscription; static void Main(string[] args) ...
Como altero a implementação do Rx Builder para corrigir a exceção de estouro de pilh
Estou tentando criar um Rx Builder para usar a extensão reativa na sintaxe da expressão de computação F #. Como faço para corrigi-lo para que ele não estrague a pilha? Como o exemplo Seq abaixo. E há planos para fornecer uma implementação do ...
Como compartilhar um observável com publicar e conectar?
Eu tenho um fluxo de dados observável ao qual estou aplicando operações, dividindo em dois fluxos separados, aplicando mais operações (distintas) a cada um dos dois fluxos e mesclando novamente. Estou tentando compartilhar o observável entre dois ...
RX - Explosões de grupo / lote de elementos em uma sequência observável
Eu tenho uma sequência observável. Quando o primeiro elemento é inserido, Gostaria de iniciar um cronômetro e agrupar os elementos inseridos subsequentes durante o período de tempo do cronômetro. Em seguida, o cronômetro não iniciaria novamente ...
Observável de tarefas encadeadas
Estou tentando criar um Observable onde cada item é produzido por meio de uma tarefa assíncrona. O próximo item deve ser produzido por meio de uma chamada assíncrona no resultado do item anterior (co-recursão). Na linguagem "Generate", isso seria ...
RxJava: como aplicar condicionalmente operadores a um observável sem quebrar a cadeia
Eu tenho uma cadeia de operadores em um observável RxJava. Eu gostaria de poder aplicar um dos dois operadores, dependendo de um valor booleano sem "quebrar a cadeia". Sou relativamente novo em Rx (Java) e sinto que provavelmente há uma ...