Return schema for the stream, if it has been received
(&self)
| 140 | |
| 141 | /// Return schema for the stream, if it has been received |
| 142 | pub fn schema(&self) -> Option<&SchemaRef> { |
| 143 | self.inner.schema() |
| 144 | } |
| 145 | |
| 146 | /// Consume self and return the wrapped [`FlightDataDecoder`] |
| 147 | pub fn into_inner(self) -> FlightDataDecoder { |