public async Task WithHandlers()

in src/Libs/Common/Redis/MessageClient.cs [62:70]


        public async Task WithHandlers(params MessageHandler[] handlers)
        {
            foreach (var handler in handlers ?? throw new ArgumentNullException(nameof(handlers)))
            {
                var cmq = await _subscriber.SubscribeAsync(
                    $"{TestId}:{handler.Role ?? _sender}:{handler.Command}:{handler.Type}");
                cmq.OnMessage(cm => handler.Handle(cm.Message));
            }
        }