Resultados da pesquisa a pedido "system.reactive"
Catching excepções que podem ser geradas a partir de uma Subscrição OnNext Action
Sou um pouco novo no Rx.NET. É possível capturar uma exceção que pode ser lançada por qualquer um dos assinantes? Faça o seguinte ... handler.FooStream.Subscribe( _ => throw new Exception("Bar"), _ => { }); Atualmente, eu entendo por ...
Usando o Rx (extensões reativas) para observar itens específicos em ObservableCollection
Tenho uma ObservableCollection que preciso fazer referência a um item específico. Se o item não estiver lá, preciso monitorá-lo por meio de extensões reativas para saber se / quando os itens aparecem, mas preciso de ajuda para configurar a ...
Qual é a diferença entre SubscribeOn e ObserveOn
Acabei de descobrirSubscribeOn, o que me faz pensar se eu deveria usá-lo em vez deObserveOn. O Google me levouaqu [http://social.msdn.microsoft.com/Forums/en-US/rx/thread/6944f097-00f4-42ad-8f19-d01d1aa939f4/] ...
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) ...
As extensões reativas suportam buffers de rolagem?
Estou usando extensões reativas para coletar dados em buffers de 100ms: this.subscription = this.dataService .Where(x => !string.Equals("FOO", x.Key.Source)) .Buffer(TimeSpan.FromMilliseconds(100)) .ObserveOn(this.dispatcherService) .Where(x => ...
possível invocar os OnNexts dos assinantes em diferentes threads no R
Sou novo no Rx. Quero saber se é possível enviar uma mensagem para diferentes assinantes, para que sejam executados em threads diferentes? Como um IObserable pode controlá-lo? A implementação simples do Subject, como eu entendo, chama ...
Existe uma maneira mais elegante de mesclar observáveis quando o tipo de retorno não é important
Tenho um modelo de exibição semelhante ao ReactiveUI. Possui várias propriedades de tipos diferentes que disparamNotifyPropertyChanged events e quero inscrever um método que será chamado quando algum for acionado, mas não estou interessado em ...
Adicionando uma sequência observável após a assinatura
Estamos usando o Rx para monitorar a atividade em nosso aplicativo silverlight, para que possamos exibir uma mensagem ao usuário após um período de inatividad Estamos transformando eventos (movimentos do mouse etc.) em observáveis e, ...
Como concluir um Rx Observable dependendo de uma condição em um evento
Tenho um evento que não estou no controle e que me fornece dados. O eventArgs se parece com isso: class MyEventArg { bool IsLastItem {get;} Data DataItem {get;} }Uso Rx para converter este evento em um IObservable. Mas quero concluir o ...
Fast Repeat TakeWhile causa loop infinito
Como posso fazer a seguinte repetição observável até stream.DataAvailable é false? Atualmente, parece que nunca para. AsyncReadChunk e Observable.Return dentro da seção Adiar, faça OnNext e OnCompleted. Quando a Repetição recebe a chamada ...