(sleepDuration time.Duration)
| 138 | } |
| 139 | |
| 140 | func NewBroadcasterForTests(sleepDuration time.Duration) EventBroadcaster { |
| 141 | return &eventBroadcasterImpl{ |
| 142 | Broadcaster: watch.NewBroadcaster(maxQueuedEvents, watch.DropIfChannelFull), |
| 143 | sleepDuration: sleepDuration, |
| 144 | } |
| 145 | } |
| 146 | |
| 147 | func NewBroadcasterWithCorrelatorOptions(options CorrelatorOptions) EventBroadcaster { |
| 148 | return &eventBroadcasterImpl{ |
no outgoing calls