Reaktif Uzantılar (RX) Özel Zamanlayıcı C#

Question

Öğeyi hangi iş parçacığı üzerinde işlemeye karar vermek için, IObservable içinden geçen her öğenin değerini denetleyebilen özel bir zamanlayıcı oluşturmak mümkün mü?

Aynı tuşa sahip öğeleri sırayla ancak farklı anahtarları paralel olarak işlemek için bir ihtiyacım var. Her bir değeri bir iş parçacığına tahsis etmek için RX'in daha önce gözlemlenebilir olandan ayrılmaktan ziyade programlamayı yapması mantıklı olacaktır.

Answer 1

GroupBy'u denediniz mi ObserveOn? gibi

şey: Bu, anahtar ile akışı bölme her anahtar için yeni bir başlık açıp bu anahtarın her öğe için process() çalışacak

source 
    .GroupBy(item => item.Key) 
    .SelectMany(group => group 
     .ObserveOn(Scheduler.NewThread) 
     .Select(item => process(item)) 
    ) 
    .Subscribe(processResult => ...); 

.