Method closeExternalOutputChans

flow/dataset_run.go:78–82

()

}

func (d *Dataset) closeExternalOutputChans() {
	for _, ch := range d.ExternalOutputChans {
		ch.Close()
	}
}