typedrest-reactive/net.typedrest.endpoints.reactive

Package-level declarations

Reactive endpoints allow you to receive data as push streams rather than explicitly pulling.

Types

GenericStreamingCollectionEndpoint

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

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

GenericStreamingCollectionEndpointImpl

open class GenericStreamingCollectionEndpointImpl<TEntity : Any, TElementEndpoint : ElementEndpoint<TEntity>>(referrer: Endpoint, relativeUri: URI, entityType: Class<TEntity>, elementEndpointFactory: (referrer: Endpoint, relativeUri: URI) -> TElementEndpoint) : GenericCollectionEndpointImpl<TEntity, TElementEndpoint> , GenericStreamingCollectionEndpoint<TEntity, TElementEndpoint>

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

PollingEndpoint

interface PollingEndpoint<TEntity : Any> : ElementEndpoint<TEntity>

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

PollingEndpointImpl

open class PollingEndpointImpl<TEntity : Any>(referrer: Endpoint, relativeUri: URI, entityType: Class<TEntity>, endCondition: (TEntity) -> Boolean? = null) : ElementEndpointImpl<TEntity> , PollingEndpoint<TEntity>

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

SseStreamingEndpointImpl

open class SseStreamingEndpointImpl<TEntity : Any>(referrer: Endpoint, relativeUri: URI, entityType: Class<TEntity>, eventType: String? = null) : AbstractEndpoint, StreamingEndpoint<TEntity>

Endpoint for a stream of TEntitys using Server-Sent Events (SSE).

StreamingCollectionEndpoint

interface StreamingCollectionEndpoint<TEntity : Any> : GenericStreamingCollectionEndpoint<TEntity, ElementEndpoint<TEntity>>

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

StreamingCollectionEndpointImpl

open class StreamingCollectionEndpointImpl<TEntity : Any> : GenericStreamingCollectionEndpointImpl<TEntity, ElementEndpoint<TEntity>> , StreamingCollectionEndpoint<TEntity>

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

StreamingEndpoint

interface StreamingEndpoint<TEntity : Any> : Endpoint

Endpoint for a stream of TEntitys.

StreamingEndpointImpl

open class StreamingEndpointImpl<TEntity : Any>(referrer: Endpoint, relativeUri: URI, entityType: Class<TEntity>, separator: String = "") : AbstractEndpoint, StreamingEndpoint<TEntity>

Endpoint for a stream of TEntitys using a persistent HTTP connection.

Functions

fun ObservableEmitter<*>.sleep(duration: Duration)

Sleep for the specified duration unless the emitter is disposed in the meantime.