Versions in this module Expand all Collapse all v1 v1.0.1 Jan 31, 2023 Changes in this version + type Subscriber struct + func Run(log slog.Logger, b broker.Broker[T], workers int, worker Worker[T], ...) *Subscriber[T] + func (s *Subscriber[T]) Stop() + func (s *Subscriber[T]) Wait() + type Worker func(queue <-chan broker.Event[T])
Go to main page