Resultados da pesquisa a pedido "system.reactive"
Existe uma maneira de armazenar uma coleção de “mensagens” de até 1 MB e gravar o resultado no arquivo JSON / CSV
Tenho uma fila de bloqueio que continua recebendo mensagens através de algum aplicativo, agora no aplicativo asp.net tentei consumir a fila e gravar a saída no arquivo CSV / JSO Aqui eu quero armazenar mensagens de até 1 MB que recebam da fila ...
Como posso esperar que tudo seja feito em uma sequência observável de Rx após o cancelamento da inscrição?
Introdução No meu aplicativo WPF C # .NET, eu uso as extensões reativas (Rx) para assinar eventos e geralmente preciso recarregar algo do banco de dados para obter os valores necessários para atualizar a interface do usuário, porque os objetos ...
Precisamos cancelar a assinatura do observável que termina / com erros?
Quando eu sei que o observável definitivamente estará completo (comcomplete ou umerror notificação)antes meu componente / classe está fora do escopo, ainda preciso cancelar a assinatura dele para evitar vazamentos de memória? Em outras palavras, ...
Observable.Generate com TimeSpan parece vazar memória [Ao usar um TimeSpan> 15ms]
Estou investigando o uso do Observable.Generate para criar uma sequência de resultados amostrados em intervalos usando os exemplos do site msdn como ponto de partida. O código a seguir SEM um seletor TimeSpan não exibe um vazamento de ...
Taxa de empacotamento que limita a chamada da API
Eu tenho acesso a uma chamada de API queaceita uma taxa máxima de chamadas por segundo. Se a taxa for excedida, umexceção é lançada. Gostaria de agrupar esta chamada em uma abstração que faça o necessário para manter a taxa de chamada abaixo do ...
Meu operador "zipLatest" já existe?
pergunta rápida sobre um operador que escrevi para mim. Por favor, desculpe os diagramas de mármore dos meus pobres: zip aa--bb--cc--dd--ee--ff--------gg --11----22--33--------44--55---- ================================ ...
O que o operador Wait no Rx.NET faz?
Na v2.2.5 da biblioteca Rx.NET, há um operador chamadoWaitque é definido da seguinte maneira: public virtual TSource Wait<TSource>(IObservable<TSource> source)Nem oreferência da biblioteca de classes no ...
Limitando solicitações simultâneas usando Rx e SelectMany
Eu tenho uma lista de URLs de páginas que eu quero baixar simultaneamente usandoHttpClient. A lista de URLs pode ser grande (100 ou mais!) Atualmente, tenho este código: var urls = new List<string> { @"http:\\www.amazon.com", ...
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 ...
RxJs: exemplo de arrastar e soltar: adicionar mousedragstart
Como implementar ummousedragstart Observável usando oArraste e solte o exemplo de RxJs [https://github.com/Reactive-Extensions/RxJS/blob/master/examples/dragndrop/dragndrop.js] . mousedragstart deve ser emitido antes do primeiromousedrag após ...