@@ -468,27 +468,23 @@ mod tests {
468468 let ctx = ArrayContext :: empty ( ) ;
469469
470470 // Write the array into a byte buffer.
471- let ( layout, _segments) = {
472- let segments = Arc :: new ( TestSegments :: default ( ) ) ;
473- let ( ptr, eof) = SequenceId :: root ( ) . split ( ) ;
474- // Only allow the dict encoding; canonical primitive children remain permitted.
475- let mut allowed = HashSet :: default ( ) ;
476- allowed. insert ( Dict . id ( ) ) ;
477- let layout = FlatLayoutStrategy :: default ( )
478- . with_allow_encodings ( allowed)
479- . write_stream (
480- ctx,
481- Arc :: < TestSegments > :: clone ( & segments) ,
482- dict. into_array ( ) . to_array_stream ( ) . sequenced ( ptr) ,
483- eof,
484- & session,
485- )
486- . await ;
487471
488- ( layout, segments)
489- } ;
472+ let segments = Arc :: new ( TestSegments :: default ( ) ) ;
473+ let ( ptr, eof) = SequenceId :: root ( ) . split ( ) ;
474+ // Only allow the dict encoding; canonical primitive children remain permitted.
475+ let mut allowed = HashSet :: default ( ) ;
476+ allowed. insert ( Dict . id ( ) ) ;
490477
491- assert ! ( layout. is_ok( ) ) ;
478+ FlatLayoutStrategy :: default ( )
479+ . with_allow_encodings ( allowed)
480+ . write_stream (
481+ ctx,
482+ Arc :: < TestSegments > :: clone ( & segments) ,
483+ dict. into_array ( ) . to_array_stream ( ) . sequenced ( ptr) ,
484+ eof,
485+ & session,
486+ )
487+ . await ?;
492488
493489 Ok ( ( ) )
494490 } )
0 commit comments