Problèmes avec l'agrégateur d'événements à l'aide d'extensions réactives

Question

Pour lier mon application MEF, j'utilise l'agrégateur d'événements found here. Il a été parfait pour distribuer des données dans des modules qui en ont réellement besoin.

Je suis de plus en utilisant les extensions réactives et j'ai essayé de faire ce qui suit:

eventSubscription = MainApp.Events.GetEvent<UDPMessageIn>() 
            .BufferWithTime(TimeSpan.FromSeconds(1)) 
            .Subscribe(x => 
             { 
              // do something here... 
             }); 

Cependant, l'agrégateur d'événements semble se bloquer dans la méthode Publier sur:

((ISubject<TEvent>)subject).OnNext(sampleEvent); 

Je suppose qu'il y a quelque chose à propos de la conception de system.reactive ou de l'agrégateur que je ne comprends pas complètement. Quelqu'un a des idées?

Answer 1

Il est avéré être un problème de filetage sans lien avec Rx ou l'agrégateur d'événements.

Changer l'un de mes UI à Invoque BeginInvoke l'a arrêté de traîner et cela m'a fait regarder les bons bits de code ...

Answer 2

Sur quels threads le producteur et le consommateur s'exécutent-ils? Sont-ils séparés?

Essayez:

.BufferWithTime(TimeSpan.FromSeconds(1), Scheduler.TaskPool);