MCPcopy Index your code
hub / github.com/coder/coder / racyPubsub

Struct racyPubsub

coderd/database/pubsub/pubsub_linux_test.go:381–383  ·  view source on GitHub ↗

racyPubsub simulates a race on the same channel by publishing two messages (one expected, one not). This is used to verify that a subscriber will only listen for the message it explicitly expects.

Source from the content-addressed store, hash-verified

379// racyPubsub simulates a race on the same channel by publishing two messages (one expected, one not).
380// This is used to verify that a subscriber will only listen for the message it explicitly expects.
381type racyPubsub struct {
382 pubsub.Pubsub
383}
384
385func newRacyPubsub(ps pubsub.Pubsub) *racyPubsub {
386 return &racyPubsub{ps}

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected