Wie Ausnahme auf einem Verhalten Thema

Question

ich ein Verhalten Thema

var source = new BehaviorSubject<int>(0); 

ich, dass dann Prozess zu handhaben Quelle mit so etwas wie

var withErrors = source 
      .Select(v => 
      { 
       if (v == 2) 
       { 
        throw new Exception("Ouch "); 
       } 
       return v; 
      }) 

ich in einer solchen Art und Weise zu withErrors abonnieren möchten, dass ich kann die Fehler überspringen. Ein Versuch mit diesem Fang.

public IObservabe<int> SkipError(IObservable<T> source){ 

    return source 
     .Catch(e=>SkipErrors(source.Skip(1)); 
} 

und dann rufen so

var withoutErrors = SkipError(withErrors); 

das Überspringen ist ein Versuch, auf das Verhalten Thema Wiederholung des letzten Fehler zu vermeiden, aber leider es nicht so funktioniert. Überspringen überspringt Fehler nicht, sondern nur über gültige Daten, so dass der Fehler vom aktuellen Zustand im Verhaltenssubjekt durchkommt.

Gibt es eine clevere Art, Skip zu schreiben, die auch Fehler überspringt. Etwas sagt mir, das ist nicht möglich, aber hoffentlich bin ich falsch

Answer 1

Da die Prämisse der Frage falsch ist, präsentiere ich eine better Weise, dies mit der Exceptional<T> Monad zu tun. Zum Beispiel

IObservable<int> source = ....; 
IObservable<Exceptional<string>> withErrors = 
    source.Select(i=>Exceptional.Execute(()=>{ 
     if(v==2){ 
      throw new Exception("Ouch"); 
     } 
     return v.ToString(); 
    }); 


IObservable<Exception> errors = 
    withErrors.Where(v=>v.HasException).select(v=>v.Exception); 

IObservable<string> values = 
    withErrors.Where(v=>!v.HasException).select(v=>v.Value); 

und nur zum Spaß können Sie

Exceptional<string> r = 
     from x in Exceptional.Execute(() => "xxx") 
     from y in Exceptional.Execute(() => "zzz") 
     select x + y; 

tun das wird Generation ein Exceptional hält den Wert "xxxzzz". Wenn einer der Schritte eine Ausnahme auslöst, wird nur die Ausnahme kurzgeschlossen und gehalten.

Meine Implementierung basiert weg eine andere SO Antwort https://gist.github.com/bradphelan/6154972