Resultados da pesquisa a pedido "system.reactive"
Pipeline reativo - como controlar o paralelismo?
Estou construindo um pipeline de processamento direto, em que um item é buscado como entrada, está sendo operado por vários processadores de maneira sequencial e, finalmente, é produzido. A imagem abaixo descreve a arquitetura geral: A maneira ...
Usando extensões reativas (Rx) para programação de soquetes é prático?
Qual é a maneira mais sucinta de escrever oGetMessages função com Rx: static void Main() { Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); var messages = GetMessages(socket, IPAddress.Loopback, 4000); ...
Rx como combinar comando com outro observável
Eu tenho vários comandos reativos, além de alguns observáveis com algumas informações, e estou tentando fazer algo como: _navigate = ReactiveCommand.Create(CanNavigate); _navigate.CombineLatest(navigationTarget, (_, tgt) => tgt) .Subscribe(tgt ...
Qual é uma boa maneira de executar tarefas periódicas em c # usando o Rx com uma única restrição de execução simultânea?
Quero executar tarefas periódicas com uma restrição de que no máximo apenas uma execução de um método esteja sendo executada a qualquer momento. Eu estava experimentando o Rx, mas não tenho certeza de como impor no máximo uma restrição de ...
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 ...
Eventos IObservable x Plain ou Por que devo usar IObservable?
A Microsoft apresentou oIObservable<T> interface [http://msdn.microsoft.com/en-us/library/dd990377.aspx]à BCL com o .NET Framework 4 e pensei: "Ótimo, finalmente, preciso usá-lo!" Então, eu procurei profundamente e li postagens e documentação e ...
As extensões reativas (Rx) podem ser usadas através dos limites do processo ou da máquina?
Lembre-se vagamente de ver algumas discussões sobre isso há um bom tempo, mas não ouvi nada desde então. Então, basicamente, você é capaz de assinar um IObservable em uma máquina remota?
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 ...
Pesquisa de banco de dados com extensões reativas
Eu tenho que consultar um banco de dados em tempo hábil para conhecer o estado de um sistema legado. Eu pensei em agrupar a consulta em torno de umObservable, mas não sei a maneira correta de fazer isso. Basicamente, será a mesma consulta a cada ...
Angular2 Observable.forkJoin de variáveis observáveis - ReferenceError: Observable não está definido
Eu gostaria de pedir ajuda. Omiti o código que suponho que não é importante. Vamos imaginar o arquivo TS que contém chamadas de serviço: // arquivo: someService.ts @Injectable() export class SomeService { method1(){ var observable ...