File tree Expand file tree Collapse file tree 2 files changed +13
-12
lines changed Expand file tree Collapse file tree 2 files changed +13
-12
lines changed Original file line number Diff line number Diff line change @@ -1431,7 +1431,7 @@ mod tests {
14311431 ) ) ;
14321432
14331433 let rows = create_cass_rows_from_rows (
1434- Some ( vec ! [ Row {
1434+ vec ! [ Row {
14351435 columns: vec![
14361436 Some ( CqlValue :: BigInt ( 42 ) ) ,
14371437 None ,
@@ -1441,11 +1441,14 @@ mod tests {
14411441 CqlValue :: Float ( 9999.9999 ) ,
14421442 ] ) ) ,
14431443 ] ,
1444- } ] ) ,
1444+ } ] ,
14451445 & metadata,
14461446 ) ;
14471447
1448- CassResult { rows, metadata }
1448+ CassResult {
1449+ rows : Some ( rows) ,
1450+ metadata,
1451+ }
14491452 }
14501453
14511454 unsafe fn cass_result_column_name_rust_str (
Original file line number Diff line number Diff line change @@ -357,7 +357,9 @@ pub unsafe extern "C" fn cass_session_execute(
357357 maybe_col_data_types,
358358 result. tracing_id ,
359359 ) ) ;
360- let cass_rows = create_cass_rows_from_rows ( result. rows , & metadata) ;
360+ let cass_rows = result
361+ . rows
362+ . map ( |rows| create_cass_rows_from_rows ( rows, & metadata) ) ;
361363 let cass_result = Arc :: new ( CassResult {
362364 rows : cass_rows,
363365 metadata,
@@ -378,19 +380,15 @@ pub unsafe extern "C" fn cass_session_execute(
378380}
379381
380382pub ( crate ) fn create_cass_rows_from_rows (
381- rows : Option < Vec < Row > > ,
383+ rows : Vec < Row > ,
382384 metadata : & Arc < CassResultData > ,
383- ) -> Option < Vec < CassRow > > {
384- let rows = rows?;
385- let cass_rows = rows
386- . into_iter ( )
385+ ) -> Vec < CassRow > {
386+ rows. into_iter ( )
387387 . map ( |r| CassRow {
388388 columns : create_cass_row_columns ( r, metadata) ,
389389 result_metadata : metadata. clone ( ) ,
390390 } )
391- . collect ( ) ;
392-
393- Some ( cass_rows)
391+ . collect ( )
394392}
395393
396394fn create_cass_row_columns ( row : Row , metadata : & Arc < CassResultData > ) -> Vec < CassValue > {
You can’t perform that action at this time.
0 commit comments