Как мне динамически обновлять / добавлять элементы в / в IObservable ?

У меня есть наблюдаемая коллекция, которой я хочу продолжать кормить объекты, и они должны доходить до наблюдателей даже после того, как кто-то подписался на нее (что, конечно же, является основной целью наблюдаемого). Как это сделать?

В следующей программе после того, как подписка произошла, я хочу ввести еще 3 числа, которые должны достичь наблюдателей. Как мне это сделать?

Я не хочу идти по пути, по которому я реализую свой собственный класс Observable, реализуя IObservable и использую метод Publish ? Есть ли другой способ добиться этого?

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);
    }
}
6
задан P.K 16 February 2012 в 16:12
поделиться