Class ThreadSwitcherSingleThread<T>

Namespace

Lykke.Common

Assembly

Lykke.Common.dll

public class ThreadSwitcherSingleThread<T> : ProducerConsumer<Tuple<Func<T, Task>, T>>, IStartStop, IStartable, IStopable, IDisposable, IThreadSwitcher<T>

Type Parameters

T

Inheritance

object

ProducerConsumer<Tuple<Func<T, Task>, T>>

ThreadSwitcherSingleThread<T>

Implements

IStartStop

IStartable

IStopable

IDisposable

IThreadSwitcher<T>

Inherited Members

ProducerConsumer<Tuple<Func<T, Task>, T>>._componentName

ProducerConsumer<Tuple<Func<T, Task>, T>>.Consume(Tuple<Func<T, Task>, T>)

ProducerConsumer<Tuple<Func<T, Task>, T>>.Consume(Tuple<Func<T, Task>, T>, CancellationToken)

ProducerConsumer<Tuple<Func<T, Task>, T>>.Produce(Tuple<Func<T, Task>, T>)

ProducerConsumer<Tuple<Func<T, Task>, T>>.Start()

ProducerConsumer<Tuple<Func<T, Task>, T>>.Stop()

ProducerConsumer<Tuple<Func<T, Task>, T>>.Dispose()

ProducerConsumer<Tuple<Func<T, Task>, T>>.Dispose(bool)

ProducerConsumer<Tuple<Func<T, Task>, T>>.ComponentName

ProducerConsumer<Tuple<Func<T, Task>, T>>.Log

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

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

ThreadSwitcherSingleThread(ILog)

[Obsolete]
public ThreadSwitcherSingleThread(ILog log)

Parameters

log ILog

ThreadSwitcherSingleThread(ILogFactory)

public ThreadSwitcherSingleThread(ILogFactory logFactory)

Parameters

logFactory ILogFactory

Methods

Consume(Tuple<Func<T, Task>, T>)

Override this method to consume next item

protected override Task Consume(Tuple<Func<T, Task>, T> item)

Parameters

item Tuple<Func<T, Task>, T>

Returns

Task

SwitchThread(Func<T, Task>, T)

public void SwitchThread(Func<T, Task> otherThread, T data)

Parameters

otherThread Func<T, Task>

data T