Resultados da pesquisa a pedido "system.reactive"
Com o MongoDB, é possível receber notificações de edições de terceiros via .NET Reactive Extensions (RX)?
Gostaria de saber se alguém sabe se é possível obter notificações ao vivo de quaisquer edições em um banco de dados MongoDB via Extensões Reativas (RX) em C #? Isso significaria que qualquer terceiro poderia editar o banco de dados MongoDB e um ...
Bom exemplo de uso de extensões reativas [fechado]
Eu entendo o básico de Rx. Onde estou lutando é como você realmente usaria isso além dos exemplos acadêmicos? Quais são alguns cenários simples e comuns do mundo real, nos quais o Rx é uma solução muito melhor do que o que temos hoje no .NET?
Posso aguardar algo se não houver um método GetAwaiter?
Vi alguns artigos sobre como projetar um tipo aguardável ...
Como criar um fluxo Rx (RxJS) que pode ser alternado entre o item único e o modo em lote?
Eu tenho um fluxo Rx que é um feed de alterações de saída de um componente específico. Ocasionalmente, quero poder inserir ummodo de lote no fluxo para que os itens passados paraonNext acumulam e são transmitidos somente quando o modo em lote ...
Por que é possível aguardar um Rx observável? [duplicado]
Esta pergunta já tem uma resposta aqui: Posso aguardar algo se não houver um método GetAwaiter? [/questions/26046775/can-i-await-something-if-theres-no-getawaiter-method] 2 respostasAcabei de notar que oawait A palavra-chave pode ser usada com o ...
Obter elemento anterior em IObservable sem reavaliar a sequência
Em umIObservable sequência (em Extensões reativas para .NET), gostaria de obter o valor dos elementos anteriores e atuais para poder compará-los. Encontrei um exemplo online semelhante ao abaixo, que realiza a ...
Como posso limpar o buffer em um ReplaySubject?
como posso limpar o buffer em um ReplaySubject? Periodicamente, preciso limpar o buffer (como um evento de final do dia no meu caso) para impedir que o ReplaySubject cresça continuamente e, eventualmente, coma toda a memória. Idealmente, quero ...
Como restringir a concorrência da maneira correta no Rx.NET
Observe o seguinte trecho de código: var result = await GetSource(1000).SelectMany(s => getResultAsync(s).ToObservable()).ToList();O problema com este código é quegetResultAsync é executado simultaneamente de maneira irrestrita. O que poderia ...
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 ...
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á ...