प्रतिक्रियाशील एक्सटेंशन (आरएक्स) कस्टम शेड्यूलर सी #

Question

कस्टम शेड्यूलर बनाना संभव है जो IObservable के माध्यम से गुजरने वाले प्रत्येक तत्व के मूल्य का निरीक्षण कर सकता है, ताकि यह तय किया जा सके कि आइटम को किस प्रक्रिया को संसाधित करना है?

मुझे समान कुंजी के साथ समान रूप से समान कुंजी के साथ आइटम को संसाधित करने की आवश्यकता है लेकिन समानांतर में अलग-अलग कुंजी। यह समझ में आता है कि RX को प्रत्येक मान को थ्रेड में आवंटित करने के लिए पहले से अधिक देखने योग्य के बजाय शेड्यूलिंग करना है।

Answer 1

क्या आपने GroupByObserveOn के बाद प्रयास किया है?

कुछ की तरह:

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

यह कुंजी द्वारा धारा विभाजन होगा, प्रत्येक कुंजी के लिए एक नया धागा शुरू, और है कि कुंजी में प्रत्येक आइटम के लिए process() चलाते हैं।