Re: ReactiveCollection

Aggelos Biboudis — Wed, 17 Apr 2013 22:25:42 GMT

Υποπτεύομαι ότι θέλει να παρεμβάλεις κάποιο TakeUntil combinator πριν το Subscribe του δεύτερου.

ReactiveCollection

KelMan — Wed, 17 Apr 2013 17:28:29 GMT

Λοιπόν, έχουμε ένα ObservableCollection που λέγεται Feeds και περιέχει κάποια URLs που είναι RSS Feeds. Φορτώνω το feed και το περνάω από ένα async process που ξεχωρίζει δύο links για κάθε item του feed. Αυτά τα ρίχνει σε ένα ReactiveCollection και μόλις πέσουν μέσα τα τσιμπάει ο subscriber του ItemsAdded και τα περνάει από ένα δεύτερο process. Δουλεύει μια χαρά. Το θέμα είναι ότι ο subscriber περιμένει συνεχώς για νέα items οπότε δεν μπορώ να ξέρω πότε έχει τελειώσει η διαδικασία. Υπάρχει τρόπος να το βελτιώσω ώστε μπορώ να ξέρω πότε έχει τελειώσει;

            source = Feeds.ToObservable();
            resourceList = new ReactiveUI.ReactiveCollection<string>();
            var source2 = resourceList.ToObservable();

 
            IObserver<Feed> obs1 = Observer.Create<Feed>
                     (
                       (x) =>
                       {
                           ProcessFeed(x);
                       },
                       (ex) => Debug.WriteLine("OnError :: " + ex.Message),
                       () => Debug.WriteLine("ProcessFeed Completed")
                     );

 
            resourceList.ItemsAdded.Subscribe(x =>
            {
                ProcessUrl(x);
            }, () => Debug.WriteLine("ProcessUrl Completed"));

 
            IDisposable sub1 = source.Subscribe(obs1);
            sub1.Dispose();

.NET Framework

Re: ReactiveCollection

ReactiveCollection