Class StreamingCollectionEndpoint<TEntity>

Namespace

TypedRest.Endpoints.Reactive

Assembly

TypedRest.Reactive.dll

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

public class StreamingCollectionEndpoint<TEntity> : StreamingCollectionEndpoint<TEntity, ElementEndpoint<TEntity>>, ICachingEndpoint, IStreamingCollectionEndpoint<TEntity, ElementEndpoint<TEntity>>, ICollectionEndpoint<TEntity, ElementEndpoint<TEntity>>, IIndexerEndpoint<ElementEndpoint<TEntity>>, IStreamingCollectionEndpoint<TEntity>, IStreamingCollectionEndpoint<TEntity, IElementEndpoint<TEntity>>, ICollectionEndpoint<TEntity>, ICollectionEndpoint<TEntity, IElementEndpoint<TEntity>>, IIndexerEndpoint<IElementEndpoint<TEntity>>, IEndpoint where TEntity : class

Type Parameters

TEntity

The type of entity the endpoint represents.

Inheritance

object

EndpointBase

CachingEndpointBase

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>

StreamingCollectionEndpoint<TEntity, ElementEndpoint<TEntity>>

StreamingCollectionEndpoint<TEntity>

Implements

ICachingEndpoint

IStreamingCollectionEndpoint<TEntity, ElementEndpoint<TEntity>>

ICollectionEndpoint<TEntity, ElementEndpoint<TEntity>>

IIndexerEndpoint<ElementEndpoint<TEntity>>

IStreamingCollectionEndpoint<TEntity>

IStreamingCollectionEndpoint<TEntity, IElementEndpoint<TEntity>>

ICollectionEndpoint<TEntity>

ICollectionEndpoint<TEntity, IElementEndpoint<TEntity>>

IIndexerEndpoint<IElementEndpoint<TEntity>>

IEndpoint

Inherited Members

StreamingCollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.HandleAsync(Func<Task<HttpResponseMessage>>, string)

StreamingCollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.PollingInterval

StreamingCollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.GetObservable(long)

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.this[string]

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.this[TEntity]

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.ReadAllAllowed

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.ReadAllAsync(CancellationToken)

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.RangeUnit

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.HandleCapabilities(HttpResponseMessage)

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.ReadRangeAllowed

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.ReadRangeAsync(RangeItemHeaderValue, CancellationToken)

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.CreateAllowed

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.CreateAsync(TEntity, CancellationToken)

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.CreateAllAllowed

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.CreateAllAsync(IEnumerable<TEntity>, CancellationToken)

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.SetAllAllowed

CollectionEndpoint<TEntity, ElementEndpoint<TEntity>>.SetAllAsync(IEnumerable<TEntity>, CancellationToken)

CachingEndpointBase.ResponseCache

CachingEndpointBase.GetContentAsync(CancellationToken, string)

CachingEndpointBase.PutContentAsync(HttpContent, CancellationToken, string)

CachingEndpointBase.DeleteContentAsync(CancellationToken, string)

EndpointBase.Uri

EndpointBase.HttpClient

EndpointBase.Serializers

EndpointBase.Serializer

EndpointBase.ErrorHandler

EndpointBase.LinkExtractor

EndpointBase.HandleAsync(Func<Task<HttpResponseMessage>>, string)

EndpointBase.FinalizeAsync(Func<Task<HttpResponseMessage>>, string)

EndpointBase.StartActivity(string)

EndpointBase.SetDefaultLink(string, string)

EndpointBase.SetDefaultLinkTemplate(string, string)

EndpointBase.GetLinks(string)

EndpointBase.Link(string)

EndpointBase.GetLinkTemplate(string)

EndpointBase.LinkTemplate(string, IDictionary<string, object>)

EndpointBase.LinkTemplate(string, object)

EndpointBase.HandleCapabilities(HttpResponseMessage)

EndpointBase.IsMethodAllowed(HttpMethod)

EndpointBase.ToString()

EndpointBase.GetConstructor<TEndpoint>()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

Constructors

StreamingCollectionEndpoint(IEndpoint, string)

Creates a new streaming collection endpoint.

public StreamingCollectionEndpoint(IEndpoint referrer, string relativeUri)

Parameters

referrer IEndpoint

The endpoint used to navigate to this one.

relativeUri string

The URI of this endpoint relative to the referrer's. Add a ./ prefix here to imply a trailing slash referrer's URI.

StreamingCollectionEndpoint(IEndpoint, Uri)

Creates a new streaming collection endpoint.

public StreamingCollectionEndpoint(IEndpoint referrer, Uri relativeUri)

Parameters

referrer IEndpoint

The endpoint used to navigate to this one.

relativeUri Uri

The URI of this endpoint relative to the referrer's.