initial test
timeout test
remove test/example racyness and allow zero pending capacity
1 more todo
reusable test components
TestStop
move add out to allow for reuse
two selects so we prefer to drain
flow benchmark
allow zero max batch size
allow zero batch timeout