typedrest-reactive/net.typedrest.endpoints.reactive/GenericStreamingCollectionEndpoint

GenericStreamingCollectionEndpoint

interface GenericStreamingCollectionEndpoint<TEntity : Any, TElementEndpoint : ElementEndpoint<TEntity>> : GenericCollectionEndpoint<TEntity, TElementEndpoint>

Endpoint for a collection of TEntitys observable as an append-only stream.

Use the more constrained StreamingCollectionEndpoint when possible.

Type Parameters

TEntity

The type of individual elements in the collection.

TElementEndpoint

The type of ElementEndpoint to provide for individual TEntitys.

Inheritors

GenericStreamingCollectionEndpointImpl

StreamingCollectionEndpoint

Properties

createAllAllowed

abstract val createAllAllowed: Boolean?

abstract val createAllowed: Boolean?

pollingInterval

abstract var pollingInterval: Duration

Interval in which requests are sent to the server. The server may update this interval via the Retry-After response header.

abstract val readAllAllowed: Boolean?

readRangeAllowed

abstract val readRangeAllowed: Boolean?

abstract val setAllAllowed: Boolean?

Functions

abstract fun create(entity: TEntity): TElementEndpoint?

abstract fun createAll(entities: Iterable<TEntity>)

abstract operator fun get(entity: TEntity): TElementEndpoint

abstract fun getObservable(startIndex: Long = 0): Observable<TEntity>

Provides an observable stream of elements.

abstract fun readAll(): List<TEntity>

abstract fun readRange(from: Long?, to: Long?): PartialResponse<TEntity>

abstract fun setAll(entities: Iterable<TEntity>)