publish runs in a Goroutine and listens on the channel publishArg. Every time a message is coming in, it calls all subscribers. We must run asynchronously because we don't know how long each subscriber needs.
()
source not stored for this graph (policy: none)
no test coverage detected