Skip to content

Commit ee1eec8

Browse files
committed
Provisional 'subscribe to all' functionality
1 parent 1e7cf1e commit ee1eec8

File tree

4 files changed

+236
-162
lines changed

4 files changed

+236
-162
lines changed

crates/core/src/subscription/module_subscription_actor.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -149,7 +149,7 @@ impl ModuleSubscriptionActor {
149149
let queries: QuerySet = subscription
150150
.query_strings
151151
.into_iter()
152-
.map(|query| compile_query(&self.relational_db, tx, &query))
152+
.map(|query| compile_query(&self.relational_db, tx, &auth, &query))
153153
.collect::<Result<_, _>>()?;
154154

155155
let sub = match self.subscriptions.iter_mut().find(|s| s.queries == queries) {

0 commit comments

Comments
 (0)