Method Close

internal/updatepipe/pubsub_pipe.go:99–101

()

}

func (p *PubSubPipe) Close() error {
	return p.PubSub.Close()
}