MCPcopy Create free account
hub / github.com/assembla/cony / Deliveries

Method Deliveries

consumer.go:31–33  ·  view source on GitHub ↗

Deliveries return deliveries shipped to this consumer this channel never closed, even on disconnects

()

Source from the content-addressed store, hash-verified

29// Deliveries return deliveries shipped to this consumer
30// this channel never closed, even on disconnects
31func (c *Consumer) Deliveries() <-chan amqp.Delivery {
32 return c.deliveries
33}
34
35// Errors returns channel with AMQP channel level errors
36func (c *Consumer) Errors() <-chan error {

Callers 6

ExampleFunction · 0.95
mainFunction · 0.95
mainFunction · 0.95
mainFunction · 0.95
TestConsumer_DeliveriesFunction · 0.80
TestConsumer_serve_forFunction · 0.80

Calls

no outgoing calls

Tested by 3

ExampleFunction · 0.76
TestConsumer_DeliveriesFunction · 0.64
TestConsumer_serve_forFunction · 0.64