Method toStream

pkg/stream/stream.go:307–314

()

}

func (ar *arrayReader[T]) toStream() *stream[T] {
	s := newStream[T](len(ar.arr) - ar.index)
	for i := ar.index; i < len(ar.arr); i++ {
		s.send(ar.arr[i], nil)
	}
	s.closeSend()
	return s
}

// multiStreamReader 合并多个流
type multiStreamReader[T any] struct {