Polling endpoint

Endpoint for a resource that can be polled for state changes.

Method	Input	Result	HTTP Verb	Description
Get observable	-	Entity stream	GET	Provides an observable stream of entity states.
Exists	-	Boolean	HEAD	Determines whether the element currently exists.
Read	-	Entity	GET	Returns the entity.
Set	Entity	Entity	PUT	Sets/replaces the entity.
Merge	Entity	Entity	PATCH	Modifies the existing entity by merging changes.
Delete	-	-	DELETE	Deletes the element.

Extends Element endpoint

Usage

C#JavaKotlin

var status = new PollingEndpoint<Status>(client, "status");

// Poll for state changes
IObservable<Status> stream = status.GetObservable(TimeSpan.FromSeconds(5));
stream.Subscribe(x => Console.WriteLine($"Status: {x.State}"));

// Use as regular element endpoint
Status current = await status.ReadAsync();
await status.SetAsync(new Status { State = "active" });

PollingEndpoint<Status> status = new PollingEndpointImpl<>(client, "status", Status.class);

// Poll for state changes
Observable<Status> stream = status.getObservable(Duration.ofSeconds(5));
stream.subscribe(x -> System.out.println("Status: " + x.getState()));

// Use as regular element endpoint
Status current = status.read();
status.set(new Status("active"));

val status = PollingEndpointImpl(client, "status", Status::class.java)

// Poll for state changes
val stream = status.getObservable(Duration.ofSeconds(5))
stream.subscribe { x -> println("Status: ${x.state}") }

// Use as regular element endpoint
val current = status.read()
status.set(Status("active"))