Redis Stream Мне нужна архитектура, управляемая событиями, ⇐ C#

[Гость]

При получении любого нового сообщения в потоке в это время должно сработать событие OnMessageReceived.

Код: Выделить всё

public event EventHandler OnMessageReceived;

var result = await redisDatabase.StreamRangeAsync(StreamName, "-", "+", 1, Order.Ascending);

protected virtual void OnMessageReceivedEvent(MqMessageReceivedEventArgs e)
{
OnMessageReceived?.Invoke(this, e);
}

Источник: https://stackoverflow.com/questions/781 ... chitecture