Method Close

cmd/test-streammanager/deliverypipe.go:243–249

()

}

func (dp *DeliveryPipe) Close() {
	dp.lock.Lock()
	dp.closed = true
	dp.lock.Unlock()

	dp.wg.Wait()
}