dequeue

package

v0.20.2 Latest Latest Go to latest Published: Oct 7, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

func Bytes(q *kernel.Dequeuer, cat string) (<-chan swarm.Msg[[]byte], chan<- swarm.Msg[[]byte])

Create pair of channels to receive and acknowledge pure binary

func Event[M, T any](q *kernel.Dequeuer, category ...string) (<-chan swarm.Msg[swarm.Event[M, T]], chan<- swarm.Msg[swarm.Event[M, T]])

Creates pair of channels to receive and acknowledge events of type T

func Typed[T any](q *kernel.Dequeuer, category ...string) (rcv <-chan swarm.Msg[T], ack chan<- swarm.Msg[T])

Creates pair of channels to receive and acknowledge messages of type T

This section is empty.