remove lifetime arg

geomedea-wasm/src/lib.rs

@@ -86,7 +86,7 @@ impl HttpReader {
 
 struct FeatureCollection(geojson::FeatureCollection);
 impl FeatureCollection {
-    async fn new(mut feature_stream: FeatureStream<'_>) -> geomedea::Result<Self> {
+    async fn new(mut feature_stream: FeatureStream) -> geomedea::Result<Self> {
         let mut geojson_feature_collection = geojson::FeatureCollection {
             bbox: None,
             features: vec![],

geomedea/src/http_reader.rs

@@ -573,7 +573,7 @@ impl Selection {
                 }
             }
         };
-        Box::pin(stream)
+        stream
     }
 
     async fn next_feature_buffer(
@@ -618,24 +618,24 @@ impl Selection {
     }
 }
 
-pub struct FeatureStream<'a> {
-    inner: Box<dyn Stream<Item = Result<Feature>> + Unpin + 'a>,
+pub struct FeatureStream {
+    inner: Box<dyn Stream<Item = Result<Feature>> + Unpin>,
 }
 
-impl<'a> FeatureStream<'a> {
-    fn new(stream: impl Stream<Item = Result<Bytes>> + Unpin + 'a) -> Self {
+impl FeatureStream {
+    fn new(stream: impl Stream<Item = Result<Bytes>> + 'static) -> Self {
         let inner = stream.map(move |feature_buffer| {
             let feature = deserialize_from::<_, Feature>(feature_buffer?.as_ref())?;
             // trace!("yielding feature: {feature:?}");
             Ok(feature)
         });
         Self {
-            inner: Box::new(inner),
+            inner: Box::new(Box::pin(inner))
         }
     }
 }
 
-impl Stream for FeatureStream<'_> {
+impl Stream for FeatureStream {
     type Item = Result<Feature>;
 
     fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {

geomedea_geozero/src/geozero_reader.rs

@@ -170,7 +170,7 @@ mod processing {
 /// # }
 /// ```
 pub async fn process_features<W: FeatureProcessor>(
-    stream: &mut FeatureStream<'_>,
+    stream: &mut FeatureStream,
     out: &mut W,
 ) -> GeozeroResult<()> {
     out.dataset_begin(None)?;