Function newRacyPubsub

coderd/database/pubsub/pubsub_linux_test.go:385–387

(ps pubsub.Pubsub)

}

func newRacyPubsub(ps pubsub.Pubsub) *racyPubsub {
	return &racyPubsub{ps}
}

func (s *racyPubsub) Subscribe(event string, listener pubsub.Listener) (cancel func(), err error) {
	return s.Pubsub.Subscribe(event, listener)