Class StreamingEndpoint<TEntity>

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

public class StreamingEndpoint<TEntity> : EndpointBase, IStreamingEndpoint<TEntity>, IEndpoint

Inherited Members: 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

Creates a new streaming endpoint.

public StreamingEndpoint(IEndpoint referrer, string relativeUri, string separator = "\n")

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.
separator string: The character sequence used to detect that a new element starts in an HTTP stream.

Creates a new streaming endpoint.

public StreamingEndpoint(IEndpoint referrer, Uri relativeUri, string separator = "\n")

referrer IEndpoint: The endpoint used to navigate to this one.
relativeUri Uri: The URI of this endpoint relative to the referrer's.
separator string: The character sequence used to detect that a new element starts in an HTTP stream.

The size of the buffer used to collect data for deserialization in bytes.

public int BufferSize { get; set; }

Provides an observable stream of entities. The observable is cold; HTTP communication only starts on Subscribe(IObserver<T>).

public virtual IObservable<TEntity> GetObservable()