File tree Expand file tree Collapse file tree
crates/core/src/subscription Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -2,7 +2,6 @@ use anyhow::Result;
22use hashbrown:: HashMap ;
33use spacetimedb_execution:: { Datastore , DeltaStore , Row } ;
44use spacetimedb_lib:: metrics:: ExecutionMetrics ;
5- use spacetimedb_primitives:: ColList ;
65use spacetimedb_sats:: product_value:: InvalidFieldError ;
76use spacetimedb_subscription:: SubscriptionPlan ;
87use spacetimedb_vm:: relation:: RelValue ;
@@ -32,14 +31,15 @@ pub fn eval_delta<'a, Tx: Datastore + DeltaStore>(
3231 let mut duplicate_rows_evaluated = 0 ;
3332 let mut duplicate_rows_sent = 0 ;
3433
35- let col_list = ColList :: from_iter ( plan. num_private_cols ( ) ..plan. num_cols ( ) ) ;
34+ // let col_list = ColList::from_iter(plan.num_private_cols()..plan.num_cols());
3635
3736 let maybe_project = |row : Row < ' a > | -> Result < RelValue < ' a > , InvalidFieldError > {
38- if plan. is_view ( ) {
39- Ok ( row. project_product ( & col_list) ?. into ( ) )
40- } else {
41- Ok ( row. into ( ) )
42- }
37+ // if plan.is_view() {
38+ // Ok(row.project_product(&col_list)?.into())
39+ // } else {
40+ // Ok(row.into())
41+ // }
42+ Ok ( row. into ( ) )
4343 } ;
4444
4545 if !plan. is_join ( ) {
You can’t perform that action at this time.
0 commit comments