Каков хороший способ создать IObservable для метода? - PullRequest
Новая
       9

Каков хороший способ создать IObservable для метода?

14 голосов
/ 04 февраля 2010

Допустим, у нас есть класс: 

public class Foo
{
   public string Do(int param)
   {
   }
}

Я хотел бы создать наблюдаемую величину, которая создается методом Do .Один из способов сделать это - создать событие, которое вызывается из Do и использовать Observable.FromEvent для создания наблюдаемой.Но почему-то мне не нравится создание события только ради задачи.Есть ли лучший способ сделать это?

Ответы [ 5 ]

8 голосов
/ 04 февраля 2010

Ответ Мэтта заставил меня задуматься об этом: 

public class Foo
{
    private readonly Subject<string> _doValues = new Subject<string>();

    public IObservable<string> DoValues { get { return _doValues; } }

    public string Do(int param)
    {
        var ret = (param * 2).ToString();
        _doValues.OnNext(ret);
        return ret;
    }
}


var foo = new Foo();
foo.DoValues.Subscribe(Console.WriteLine);
foo.Do(2);
1 голос
/ 13 февраля 2012

Как правило, вы хотите избежать использования предметов. В моем опыте это признак того, что вы делаете что-то не так. Observable.Create или, возможно, Generate, как правило, лучше подходит.

Мне было бы интересно посмотреть, что вы на самом деле пытаетесь сделать, чтобы увидеть, можем ли мы дать лучший ответ. Lee

1 голос
/ 04 февраля 2010

Я предполагаю, что вы управляете классом Foo, поскольку вы говорите о добавлении в него события как одного из вариантов.Поскольку у вас есть класс, есть ли причина, по которой вы не можете определить собственную реализацию IObservable для метода Do? 

public class Foo
{
    DoObservable _doValues = new DoObservable();

    public IObservable<String> DoValues
    {
        return _doValues;
    }

    public string Do(int param)
    {
        string result;
        // whatever
        _doValues.Notify(result);
    }
}

public class DoObservable : IObservable<String>
{
    List<IObserver<String>> _observers = new List<IObserver<String>>();

    public void Notify(string s)
    {
        foreach (var obs in _observers) obs.OnNext(s);
    }

    public IObserver<String> Subscribe(IObserver<String> observer)
    {
        _observers.Add(observer);
        return observer;
    }
}

В вашем классе теперь есть свойство Observable<String>, которое предоставляет способ подписки назначения, возвращаемые методом Do: 

public class StringWriter : IObserver<String>
{
    public void OnNext(string value)
    {
        Console.WriteLine("Do returned " + value);
    }

    // and the other IObserver<String> methods
}

var subscriber = myFooInstance.DoValues.Subscribe(new StringWriter());
// from now on, anytime myFooInstance.Do() is called, the value it 
// returns will be written to the console by the StringWriter observer.

Я не слишком увлекался реактивной структурой, но я думаю, что это близко к тому, как вы это сделаете.

0 голосов
/ 30 сентября 2016

Observable.Generate решает вашу проблему, хотя вам не нужно использовать условие и продолжить для вашего образца. Это просто создает и возражает и постоянно возвращает результат вызова DoIt (): 

Observable.Generate (
  new Foo(),
  item => true, // in your example, this never terminates
  item => item, // we don't actually do any state transitions
  item => { return item.DoIt(); }  // This is where we emit our value
  );

На практике вы часто хотите отслеживать какое-то состояние и иметь условие завершения. Создать это легко.

0 голосов
/ 05 февраля 2010

Я бы посмотрел на модель EventAggregator.Есть отличная статья с примером кода, которая показывает реализацию с StructureMap.

http://www.codeproject.com/KB/architecture/event_aggregator.aspx

...