Class HttpResponseStreamProvider

Namespace

CarinaStudio.Net.Http

Assembly

CarinaStudio.AppBase.Core.dll

Implementation of IStreamProvider which send HTTP request and get Stream of response.

public class HttpResponseStreamProvider : BaseDisposable, IDisposable, IStreamProvider

Inheritance

object

BaseDisposable

HttpResponseStreamProvider

Implements

IDisposable

IStreamProvider

Inherited Members

BaseDisposable.Dispose()

BaseDisposable.IsDisposed

BaseDisposable.VerifyDisposed()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

StreamProviderExtensions.CanOpenRead(IStreamProvider)

StreamProviderExtensions.CanOpenWrite(IStreamProvider)

StreamProviderExtensions.OpenStreamAsync(IStreamProvider, StreamAccess)

StreamProviderExtensions.OpenStreamReaderAsync(IStreamProvider, StreamAccess, Encoding)

StreamProviderExtensions.OpenStreamReaderAsync(IStreamProvider, StreamAccess, Encoding, CancellationToken)

DisposableExtensions.DisposeAndReturnNull<T>(T?)

DisposableExtensions.ExchangeAsync<T, R>(T, Func<T, Task<R?>>)

DisposableExtensions.ExchangeAsync<T, R>(T, Func<Task<R?>>)

DisposableExtensions.Exchange<T, R>(T, Func<T, R?>)

DisposableExtensions.Exchange<T, R>(T, Func<R?>)

DisposableExtensions.SetupAsync<T>(T, Func<T, Task>)

DisposableExtensions.SetupAsync<T>(T, Func<Task>)

DisposableExtensions.Setup<T>(T, Action)

DisposableExtensions.Setup<T>(T, Action<T>)

DisposableExtensions.UseAsync<T>(T, Func<T, Task>)

DisposableExtensions.UseAsync<T, R>(T, Func<T, Task<R>>)

DisposableExtensions.Use<T>(T, Action<T>)

DisposableExtensions.Use<T, R>(T, RefOutFunc<T, R>)

DisposableExtensions.Use<T, R>(T, Func<T, R>)

ObjectExtensions.AddWeakEventHandler<TObject>(TObject, string, Action)

ObjectExtensions.AddWeakEventHandler<TObject>(TObject, string, EventHandler)

ObjectExtensions.AddWeakEventHandler<TObject, TArg>(TObject, string, Action<TArg>)

ObjectExtensions.AddWeakEventHandler<TObject, TArgs>(TObject, string, EventHandler<TArgs>)

ObjectExtensions.AddWeakEventHandler<TObject, TArg1, TArg2>(TObject, string, Action<TArg1, TArg2>)

ObjectExtensions.AddWeakEventHandler<TObject, TArg1, TArg2, TArg3>(TObject, string, Action<TArg1, TArg2, TArg3>)

ObjectExtensions.AlsoAsync<T>(T, Func<T, Task>)

ObjectExtensions.Also<T>(T, Action<T>)

ObjectExtensions.AsNonNull<T>(T?)

ObjectExtensions.LetAsync<T>(T, Func<T, Task>)

ObjectExtensions.LetAsync<T, R>(T, Func<T, Task<R>>)

ObjectExtensions.Let<T>(T, Action<T>)

ObjectExtensions.Let<T, R>(T, RefOutFunc<T, R>)

ObjectExtensions.Let<T, R>(T, Func<T, R>)

ObjectExtensions.LockAsync<T>(T, Func<T, Task>)

ObjectExtensions.LockAsync<T>(T, Func<Task>)

ObjectExtensions.LockAsync<T, R>(T, Func<T, Task<R>>)

ObjectExtensions.LockAsync<T, R>(T, Func<Task<R>>)

ObjectExtensions.Lock<T>(T, Action)

ObjectExtensions.Lock<T>(T, Action<T>)

ObjectExtensions.Lock<T, R>(T, RefOutFunc<T, R>)

ObjectExtensions.Lock<T, R>(T, RefOutFunc<R>)

ObjectExtensions.Lock<T, R>(T, Func<T, R>)

ObjectExtensions.Lock<T, R>(T, Func<R>)

ObjectExtensions.TryCastAndRunAsync<T>(object?, Func<T, Task>)

ObjectExtensions.TryCastAndRunAsync<T, R>(object?, Func<T, Task<R>>)

ObjectExtensions.TryCastAndRun<T>(object?, Action<T>)

ObjectExtensions.TryCastAndRun<T, R>(object?, Func<T, R>)

Constructors

HttpResponseStreamProvider(Func<HttpRequestMessage>, TimeSpan?, HttpMessageHandler?, long?)

Initialize new HttpResponseStreamProvider instance.

Function to provide HttpRequestMessage. Timeout of getting HTTP response. The HTTP handler stack to use for sending requests. Maximum buffer size for response content.

public HttpResponseStreamProvider(Func<HttpRequestMessage> requestProvider, TimeSpan? timeout = null, HttpMessageHandler? messageHandler = null, long? maxResponseContentBufferSize = null)

Parameters

requestProvider Func<HttpRequestMessage>

timeout TimeSpan?

messageHandler HttpMessageHandler

maxResponseContentBufferSize long?

Methods

CheckStreamAccess(StreamAccess)

Check whether given access to Stream is supported by this provider or not.

public bool CheckStreamAccess(StreamAccess access)

Parameters

access StreamAccess

Access to stream.

Returns

bool

True if given combination of access is supported.

Dispose(bool)

Called to dispose instance.

protected override void Dispose(bool disposing)

Parameters

disposing bool

True to release managed resources also.

OpenStreamAsync(StreamAccess, CancellationToken)

Open stream asynchronously.

public Task<Stream> OpenStreamAsync(StreamAccess access, CancellationToken token)

Parameters

access StreamAccess

Desired access to stream.

token CancellationToken

Cancellation token.

Returns

Task<Stream>

Task of opening stream.