Class PublisherSubscriberMemory<T>

Namespace

Common

Assembly

Lykke.Common.dll

public class PublisherSubscriberMemory<T> : IMessageProducer<T>, IMessageConsumer<T>

Type Parameters

T

Inheritance

object

PublisherSubscriberMemory<T>

Implements

IMessageProducer<T>

IMessageConsumer<T>

Inherited Members

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

PublisherSubscriberMemory()

public PublisherSubscriberMemory()

Methods

ProduceAsync(T)

public Task ProduceAsync(T message)

Parameters

message T

Returns

Task

Subscribe(Func<T, Task>)

public void Subscribe(Func<T, Task> callback)

Parameters

callback Func<T, Task>