Skip to content

Instantly share code, notes, and snippets.

@anaisbetts
Created June 14, 2011 16:46
Show Gist options
  • Select an option

  • Save anaisbetts/1025307 to your computer and use it in GitHub Desktop.

Select an option

Save anaisbetts/1025307 to your computer and use it in GitHub Desktop.
public static Func<T1, IObservable<TRet>> FromRestSharpPattern<T1, TRet>(Action<T1, Action<TRet>> restSharpFunc)
{
return new Func<T1, IObservable<TRet>>(param => {
var retObs = new AsyncSubject<TRet>();
try {
restSharpFunc(param, returnValue => {
retObs.OnNext(returnValue);
retObs.OnCompleted();
});
} catch (Exception ex) {
retObs.OnError(ex);
}
return retObs;
});
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment