bytes

Documentation

Index

• func Dequeue(q swarm.Queue, cat string) (<-chan *swarm.Msg[[]byte], chan<- *swarm.Msg[[]byte])
• func Enqueue(q swarm.Queue, cat string) (chan<- []byte, <-chan []byte)

Functions

func Dequeue

func Dequeue(q swarm.Queue, cat string) (<-chan *swarm.Msg[[]byte], chan<- *swarm.Msg[[]byte])

DequeueBytes creates channels to receive binary messages and send acknowledgement

func Enqueue

func Enqueue(q swarm.Queue, cat string) (chan<- []byte, <-chan []byte)

Enqueue creates channels to enqueue binary messages and receive dead-letters