Make ArrayStreamAdapter only accept relevant stream (#4694)

AdamGS · web-flow · commit b6c23b60160f · 2025-09-23T09:11:47.000Z
Signed-off-by: Adam Gutglick &lt;adam@spiraldb.com&gt;
diff --git a/vortex-array/src/stream/adapter.rs b/vortex-array/src/stream/adapter.rs
@@ -20,7 +20,10 @@ pub struct ArrayStreamAdapter<S> {
     inner: S,
 }
 
-impl<S> ArrayStreamAdapter<S> {
+impl<S> ArrayStreamAdapter<S>
+where
+    S: Stream<Item = VortexResult<ArrayRef>>,
+{
     pub fn new(dtype: DType, inner: S) -> Self {
         Self { dtype, inner }
     }

Original file line number	Diff line number	Diff line change
`@@ -20,7 +20,10 @@ pub struct ArrayStreamAdapter<S> {`
`20`	`20`	`inner: S,`
`21`	`21`	`}`
`22`	`22`
`23`		`-impl<S> ArrayStreamAdapter<S> {`
	`23`	`+impl<S> ArrayStreamAdapter<S>`
	`24`	`+where`
	`25`	`+ S: Stream<Item = VortexResult<ArrayRef>>,`
	`26`	`+{`
`24`	`27`	`pub fn new(dtype: DType, inner: S) -> Self {`
`25`	`28`	`Self { dtype, inner }`
`26`	`29`	`}`