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 + func Dequeue(q swarm.Broker, cat string) (<-chan swarm.Msg[[]byte], chan<- swarm.Msg[[]byte]) + func Enqueue(q swarm.Broker, cat string) (chan<- []byte, <-chan []byte) + type Enqueuer interface + Enq func(string, []byte) error + Put func([]byte) error + func New(q swarm.Broker, category string) Enqueuer Other modules containing this package github.com/fogfish/swarm
Go to main page