Function newMultiStreamReader

pkg/stream/stream.go:323–333

(streams []*stream[T], names []string)

}

func newMultiStreamReader[T any](streams []*stream[T], names []string) *multiStreamReader[T] {
	nonClosed := make([]int, len(streams))
	for i := range streams {
		nonClosed[i] = i
	}
	return &multiStreamReader[T]{
		streams:     streams,
		nonClosed:   nonClosed,
		sourceNames: names,
	}
}

func (msr *multiStreamReader[T]) recv() (T, error) {
	var zero T