fix another documentation
This commit is contained in:
parent
e052e0e5c5
commit
d8916d8b63
@ -44,8 +44,8 @@ func (b *Batcher) Next() []Transferable {
|
|||||||
return <-b.batchReady
|
return <-b.batchReady
|
||||||
}
|
}
|
||||||
|
|
||||||
// Exit stops all batching and allows Next() to return. Calling Add() after
|
// Exit stops all batching and allows Next() to return. Calling Add() will
|
||||||
// calling Exit() will result in a panic, unless Reset() is called first.
|
// reset the batcher.
|
||||||
func (b *Batcher) Exit() {
|
func (b *Batcher) Exit() {
|
||||||
atomic.StoreUint32(&b.exited, 1)
|
atomic.StoreUint32(&b.exited, 1)
|
||||||
close(b.input)
|
close(b.input)
|
||||||
|
Loading…
Reference in New Issue
Block a user