Method
Publish
(event string, message []byte)
Source from the content-addressed store, hash-verified
| 395 | } |
| 396 | |
| 397 | func (s *racyPubsub) Publish(event string, message []byte) error { |
| 398 | err := s.Pubsub.Publish(event, []byte("nonsense")) |
| 399 | if err != nil { |
| 400 | return xerrors.Errorf("failed to send simulated race: %w", err) |
| 401 | } |
| 402 | return s.Pubsub.Publish(event, message) |
| 403 | } |
| 404 | |
| 405 | func (s *racyPubsub) Close() error { |
| 406 | return s.Pubsub.Close() |
Callers
nothing calls this directly
Tested by
no test coverage detected