async messed upp

Author: Rickard Lundin

src/chunked/arrow_converter.rs

@@ -262,8 +262,11 @@ impl<'a> Converter<'a> for Slice2Arrow<'a> {
         let emptyrb = arrow::record_batch::RecordBatch::new_empty(Arc::new(schema));
         let c = self.consistent_counter.get();
         let _ = &self.masterbuilders.sender.clone().unwrap().send(c, emptyrb);
-        
-        
+
+        //     jh.spawn_blocking(async move {threaded_writer.1.await;});
+//        threaded_writer.1.await.expect("The task being joined has panicked");;
+
+
     }
 }
 

src/chunked/residual_slicer.rs

@@ -142,6 +142,12 @@ impl<'a> Slicer<'a> for ResidualSlicer<'a> {
         info!("about to shudown converter...");
 
         converter.shutdown(threaded_writer.1);
+//        let hhh=threaded_writer.1;
+//        rt.spawn(async {
+//            hhh.await.unwrap();            
+//        });
+        
+        //        rt.spawn_blocking(async move {threaded_writer.1.await;});
 //        threaded_writer.1.await.expect("The task being joined has panicked");;
         info!("converter has been shutdown");