mirror of
https://github.com/lancedb/lancedb.git
synced 2026-01-05 11:22:58 +00:00
b8a1719174
this bumps napi version to 2.16 which contains a few bug fixes. Additionally, it adds `catch_unwind` to any method that may unintentionally panic. `catch_unwind` will unwind the panics and return a regular JS error instead of panicking.
48 lines
1.6 KiB
Rust
48 lines
1.6 KiB
Rust
// Copyright 2024 Lance Developers.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
use futures::StreamExt;
|
|
use lancedb::arrow::SendableRecordBatchStream;
|
|
use lancedb::ipc::batches_to_ipc_file;
|
|
use napi::bindgen_prelude::*;
|
|
use napi_derive::napi;
|
|
|
|
/** Typescript-style Async Iterator over RecordBatches */
|
|
#[napi]
|
|
pub struct RecordBatchIterator {
|
|
inner: SendableRecordBatchStream,
|
|
}
|
|
|
|
#[napi]
|
|
impl RecordBatchIterator {
|
|
pub(crate) fn new(inner: SendableRecordBatchStream) -> Self {
|
|
Self { inner }
|
|
}
|
|
|
|
#[napi(catch_unwind)]
|
|
pub async unsafe fn next(&mut self) -> napi::Result<Option<Buffer>> {
|
|
if let Some(rst) = self.inner.next().await {
|
|
let batch = rst.map_err(|e| {
|
|
napi::Error::from_reason(format!("Failed to get next batch from stream: {}", e))
|
|
})?;
|
|
batches_to_ipc_file(&[batch])
|
|
.map_err(|e| napi::Error::from_reason(format!("Failed to write IPC file: {}", e)))
|
|
.map(|buf| Some(Buffer::from(buf)))
|
|
} else {
|
|
// We are done with the stream.
|
|
Ok(None)
|
|
}
|
|
}
|
|
}
|