• Daniel Martí's avatar
    Fix race condition in watch · ad243eda
    Daniel Martí authored
    The Shutdown() call returned immediately, without waiting for all event
    distributions to be completed. Even worse, it would close all the watcher
    result channels before all the info was sent to them.
    
    Properly wait for all distributor goroutines - currently only one - to be
    finished.
    
    This fixes the flaky test TestBroadcasterDropIfChannelFull. Bonus cleanup on
    said test too.
    ad243eda
Name
Last commit
Last update
..
json Loading commit data...
doc.go Loading commit data...
filter.go Loading commit data...
filter_test.go Loading commit data...
iowatcher.go Loading commit data...
iowatcher_test.go Loading commit data...
mux.go Loading commit data...
mux_test.go Loading commit data...
watch.go Loading commit data...
watch_test.go Loading commit data...