Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
robert3005 committed May 23, 2024
1 parent 51116cb commit 5e61a28
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions vortex-ipc/src/writer.rs
Original file line number Diff line number Diff line change
@@ -1,8 +1,7 @@
use futures_util::{Stream, TryStreamExt};

use vortex::{Array, IntoArrayData, ViewContext};
use vortex::array::chunked::ChunkedArray;
use vortex::stream::ArrayStream;
use vortex::{Array, IntoArrayData, ViewContext};
use vortex_buffer::Buffer;
use vortex_dtype::DType;
use vortex_error::{vortex_bail, VortexResult};
Expand Down Expand Up @@ -68,8 +67,8 @@ impl<W: VortexWrite> ArrayWriter<W> {
}

async fn write_array_chunks<S>(&mut self, mut stream: S) -> VortexResult<ChunkLayout>
where
S: Stream<Item=VortexResult<Array>> + Unpin,
where
S: Stream<Item = VortexResult<Array>> + Unpin,
{
let mut byte_offsets = vec![self.msgs.tell()];
let mut row_offsets = vec![0];
Expand Down

0 comments on commit 5e61a28

Please sign in to comment.