зеркало из https://github.com/docker/go-events.git
22 строки
398 B
Go
22 строки
398 B
Go
package events
|
|
|
|
import "testing"
|
|
|
|
func TestFilter(t *testing.T) {
|
|
const nevents = 100
|
|
ts := newTestSink(t, nevents/2)
|
|
filter := NewFilter(ts, MatcherFunc(func(event Event) bool {
|
|
i, ok := event.(int)
|
|
return ok && i%2 == 0
|
|
}))
|
|
|
|
for i := 0; i < nevents; i++ {
|
|
if err := filter.Write(i); err != nil {
|
|
t.Fatalf("unexpected error writing event: %v", err)
|
|
}
|
|
}
|
|
|
|
checkClose(t, filter)
|
|
|
|
}
|