Class TimeSensitiveChannel<TRequest, TResponse>

Inheritance

object

DisposableReactiveObject

TimeSensitiveChannel<TRequest, TResponse>

TimeSensitiveChannel<T>

Implements

IDisposable

INotifyPropertyChanged

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: EyeAuras.Shared.Scaffolding

Assembly: EyeAuras.Shared.Metadata.dll

Syntax

public class TimeSensitiveChannel<TRequest, TResponse> : DisposableReactiveObject, IDisposable, INotifyPropertyChanged

Type Parameters

Name	Description
TRequest
TResponse

Constructors

Name	Description
TimeSensitiveChannel(IFluentLog, Func<TRequest, CancellationToken, Task<TResponse>>, string)

Properties

Name	Description
BackBufferPressureStrategy
DefaultRequest
IsRunning
IsTicking
Log
MinTickTime
Name
TaskCreationOptions
TerminationTimeout	When disposed, TSC will give some time for child task(if running) to complete. Blocking wait! Will throw an exception otherwise. If set to 0 will skip the check and return momentarily

Methods

Name	Description
CancelRunning()
FormatToString(ToStringBuilder)
ProcessOnDemand(TRequest, CancellationToken)

Extension Methods

ObjectExtensions.AddTo<TItem, TCollection>(TItem, ISourceList<TCollection>)

ObjectExtensions.AddTo<TItem, TCollection>(TItem, ICollection<TCollection>)

ObjectExtensions.CloneJson<T>(T)

ObjectExtensions.CopyPropertiesTo<TSource, TTarget>(TSource, TTarget)

ObjectExtensions.DumpToJson<T>(T)

ObjectExtensions.DumpToTextRaw<T>(T)

ObjectExtensions.DumpToText<T>(T)

ObjectExtensions.Dump<T>(T)

ObjectExtensions.EvalOrDefault<T, TValue>(T, Func<T, TValue>, TValue)

ObjectExtensions.Eval<T, TValue>(T, Func<T, TValue>)

ObjectExtensions.GetPropertyAccessor<TSource, TValue>(TSource, Expression<Func<TSource, TValue>>)

ObjectExtensions.InsertTo<TItem, TCollection>(TItem, IList<TCollection>, int)

ObjectExtensions.ToJson<T>(T, Formatting)

ObjectExtensions.ToStringSafe<T>(T)

ObjectExtensions.TransferPropertiesTo<TSource, TTarget>(TSource, TTarget, params string[])

ObjectExtensions.WaitForAsync<TObject, T1>(TObject, Func<TObject, T1>, Predicate<T1>, TimeSpan, int)

XDocumentExtensions.AddTo<T>(T, XContainer)

ObjectExtensions.GetPropertyAccessor<TValue>(object, string)

ObjectReflectionExtensions.GetPropertyTypeOrDefault(object, string)

ObjectReflectionExtensions.GetPropertyValue<T>(object, string)

ObjectReflectionExtensions.SetPropertyValue<T>(object, string, T)