()
| 143 | |
| 144 | #[tokio::test] |
| 145 | async fn test_zero_batches_schema_specified() { |
| 146 | let schema = Arc::new(Schema::new(vec![Field::new("a", DataType::Int64, false)])); |
| 147 | let stream = FlightDataEncoderBuilder::default() |
| 148 | .with_schema(schema.clone()) |
| 149 | .build(futures::stream::iter(vec![])); |
| 150 | |
| 151 | let mut decoder = FlightRecordBatchStream::new_from_flight_data(stream); |
| 152 | assert!(decoder.schema().is_none()); |
| 153 | // No batches come out |
| 154 | assert!(decoder.next().await.is_none()); |
| 155 | // But schema has been received correctly |
| 156 | assert_eq!(decoder.schema(), Some(&schema)); |
| 157 | } |
| 158 | |
| 159 | #[tokio::test] |
| 160 | async fn test_with_flight_descriptor() { |
nothing calls this directly
no test coverage detected