MCPcopy Index your code
hub / github.com/foxcpp/maddy / PubSubPipe

Struct PubSubPipe

internal/updatepipe/pubsub_pipe.go:14–17  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

12)
13
14type PubSubPipe struct {
15 PubSub pubsub.PubSub
16 Log *log.Logger
17}
18
19func (p *PubSubPipe) Listen(upds chan<- mess.Update) error {
20 go func() {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected