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.
| 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. |
| 381 | type racyPubsub struct { |
| 382 | pubsub.Pubsub |
| 383 | } |
| 384 | |
| 385 | func newRacyPubsub(ps pubsub.Pubsub) *racyPubsub { |
| 386 | return &racyPubsub{ps} |
nothing calls this directly
no outgoing calls
no test coverage detected