Skip to content

Instantly share code, notes, and snippets.

@bamboo
Last active December 14, 2015 09:28
Show Gist options
  • Save bamboo/5064727 to your computer and use it in GitHub Desktop.
Save bamboo/5064727 to your computer and use it in GitHub Desktop.
naive ServiceStack => ReactiveExtensions mapping
public class ObservableServiceClient : IObservableServiceClient
{
private readonly string _baseUri;
public ObservableServiceClient(string baseUri)
{
_baseUri = baseUri;
}
public IObservable<TResponse> ObserveMany<TResponse>(IReturn<IEnumerable<TResponse>> request)
{
return Observable.Start(() =>
{
var client = new JsonServiceClient(_baseUri);
return client.Send(request);
}).SelectMany(_ => _);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment