Come aggiornare/aggiungere articoli in/a un IObservable <int> in modo dinamico?

Question

Ho una collezione osservabile a cui voglio continuare a dare da mangiare agli oggetti e che dovrebbero raggiungere gli osservatori anche dopo che qualcuno li ha sottoscritti (che naturalmente è lo scopo principale di un osservabile). Come lo faccio?

Nel seguente programma, dopo che è stato effettuato l'abbonamento, desidero alimentare altri 3 numeri che dovrebbero raggiungere gli osservatori. Come faccio a fare questo?

non voglio andare via il percorso dove implemento mia classe Observable implementando IObservable<int> e utilizzare Publish metodo? C'è un altro modo per raggiungere questo obiettivo?

public class Program 
{ 
    static void Main(string[] args) 
    { 
     var collection = new List<double> { 1, 2, 3, 4, 5, 6, 7, 8, 9 }; 
     var observableCollection = collection.ToObservable(); 
     observableCollection.Subscribe(OnNext); 
     //now I want to add 100, 101, 102 which should reach my observers 
     //I know this wont' work 
     collection.Add(100); 
     collection.Add(101); 
     collection.Add(102); 
     Console.ReadLine(); 
    } 

    private static void OnNext(double i) 
    { 
     Console.WriteLine("OnNext - {0}", i); 
    } 
} 

Answer 1

Questo è quello che farei:

var subject = new Subject<double>(); 
    var collection = new List<double> { 1, 2, 3, 4, 5, 6, 7, 8, 9 }; 
    var observableCollection = collection 
     .ToObservable() 
     .Concat(subject); //at the end of the original collection, add the subject 
    observableCollection.Subscribe(OnNext); 

    //now I want to add 100, 101, 102 which should reach my observers 
    subject.OnNext(100); 
    subject.OnNext(101); 
    subject.OnNext(102); 

In generale, se si può osservare tutto ciò che sta producendo l'input aggiuntivo, che ci si vuole concat che osservabili, piuttosto che spingere imperativamente questi valori in un soggetto, ma a volte non è pratico.