Versions in this module Expand all Collapse all v0 v0.16.1 Sep 25, 2024 v0.16.0 Sep 25, 2024 Changes in this version + const Version + func Dequeue[T any](q swarm.Broker, category ...string) (<-chan swarm.Msg[T], chan<- swarm.Msg[T]) + func Enqueue[T any](q swarm.Broker, category ...string) (chan<- T, <-chan T) + func Must(broker swarm.Broker, err error) swarm.Broker + func TypeOf[T any]() string + type Enqueuer interface + Enq func(string, T) error + Put func(T) error + func New[T any](q swarm.Broker, category ...string) Enqueuer[T] Other modules containing this package github.com/fogfish/swarm
Go to main page