Method callFinishFn

asyncbuffer/buffer.go:302–310

callFinishFn calls the finish functions registered with the AsyncBuffer.

()

// callFinishFn calls the finish functions registered with the AsyncBuffer.
func (ab *AsyncBuffer) callFinishFn() {
	ab.finishOnce.Do(func() {
		for _, fn := range ab.finishFn {
			if fn != nil {
				fn()
			}
		}
	})
}

func (ab *AsyncBuffer) setErr(err error) {
	if err == nil {