RestAPI

Declarative HTTP client interfaces (Refit-style attributes) with implementations generated at compile time.

Packages

Package	Return types
Observables.RestAPI.R3	Task<T>, R3 Observable<T>, …
Observables.RestAPI.Reactive	Task<T>, IObservable<T>, …

Both include the Observables.RestAPI runtime. Reactive package also needs System.Reactive (and may require R3 at runtime for shared core types).

Define an API

using Observables.RestAPI;
using R3;

public interface IUserApi
{
    [Get("/users/{id}")]
    Task<User> GetUserAsync(int id);

    [Get("/users/{id}")]
    Observable<User> GetUserObservable(int id);
}

var api = RestService.For<IUserApi>(httpClient);
User user = await api.GetUserAsync(42);
User reactive = await api.GetUserObservable(7).FirstAsync();

Use FirstAsync (with a cancellation token in apps) for single-response observables. Errors surface as ApiException (same family as Refit).

System.Reactive

using System.Reactive.Linq;
using System.Reactive.Threading.Tasks;

User user = await api.GetUserObservable(7).FirstAsync().ToTask();

Diagnostics

See Diagnostics.

Samples

• Observables.Samples.RestAPI
• Observables.Samples.RestAPI.Reactive