Delegate ProducerConsumerConsumedEventHandler<T>

Namespace

Common

Assembly

Lykke.Common.dll

Consumed handler delegate

public delegate Task ProducerConsumerConsumedEventHandler<T>(IProducerConsumerTrigger<T> producer, ProducerConsumerConsumedHandlerArgs<T> args, CancellationToken cancellationToken)

Parameters

producer IProducerConsumerTrigger<T>

Producer-consumer, which has triggered consume of the item

args ProducerConsumerConsumedHandlerArgs<T>

Event arguments

cancellationToken CancellationToken

Cancellation token, which will be cancelled, if Stop() is being called

Returns

Task

Type Parameters

T

Type of the item to consume

Extension Methods

JsonSerialisersExt.ToJson(object, bool)

PrivateInfoExt.HidePrivateInfo<T>(object)

ReflectionUtils.PopulateObject(object, Func<PropertyInfo, object>)

UrlUtils.FormatUrlString(object, params string[])

UrlUtils.ToUrlParamString(object, ILog, params string[])

UrlUtils.ToUrlParamString(object, params string[])

Constructors

ProducerConsumerConsumedEventHandler(object, nint)

public ProducerConsumerConsumedEventHandler(object @object, nint method)

Parameters

object object

method nint

Methods

BeginInvoke(IProducerConsumerTrigger<T>, ProducerConsumerConsumedHandlerArgs<T>, CancellationToken, AsyncCallback, object)

public virtual IAsyncResult BeginInvoke(IProducerConsumerTrigger<T> producer, ProducerConsumerConsumedHandlerArgs<T> args, CancellationToken cancellationToken, AsyncCallback callback, object @object)

Parameters

producer IProducerConsumerTrigger<T>

args ProducerConsumerConsumedHandlerArgs<T>

cancellationToken CancellationToken

callback AsyncCallback

object object

Returns

IAsyncResult

EndInvoke(IAsyncResult)

public virtual Task EndInvoke(IAsyncResult result)

Parameters

result IAsyncResult

Returns

Task

Invoke(IProducerConsumerTrigger<T>, ProducerConsumerConsumedHandlerArgs<T>, CancellationToken)

public virtual Task Invoke(IProducerConsumerTrigger<T> producer, ProducerConsumerConsumedHandlerArgs<T> args, CancellationToken cancellationToken)

Parameters

producer IProducerConsumerTrigger<T>

args ProducerConsumerConsumedHandlerArgs<T>

cancellationToken CancellationToken

Returns

Task