Use take rather than get

open-chat-labs · Jan 23, 2024 · b814133 · b814133
1 parent 5081217
commit b814133
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/backend/canisters/local_user_index/impl/src/jobs/sync_events_to_user_canisters.rs b/backend/canisters/local_user_index/impl/src/jobs/sync_events_to_user_canisters.rs
@@ -22,7 +22,7 @@ pub(crate) fn start_job_if_required(state: &RuntimeState) -> bool {
 
 pub(crate) fn try_run_now(state: &mut RuntimeState) -> bool {
     if let Some(batch) = next_batch(state) {
-        if let Some(timer_id) = TIMER_ID.get() {
+        if let Some(timer_id) = TIMER_ID.take() {
             ic_cdk_timers::clear_timer(timer_id);
         }
         ic_cdk::spawn(process_batch(batch));

diff --git a/backend/canisters/local_user_index/impl/src/jobs/sync_events_to_user_index_canister.rs b/backend/canisters/local_user_index/impl/src/jobs/sync_events_to_user_index_canister.rs
@@ -22,7 +22,7 @@ pub(crate) fn start_job_if_required(state: &RuntimeState) -> bool {
 
 pub(crate) fn try_run_now(state: &mut RuntimeState) -> bool {
     if let Some((canister_id, events)) = next_batch(state) {
-        if let Some(timer_id) = TIMER_ID.get() {
+        if let Some(timer_id) = TIMER_ID.take() {
             ic_cdk_timers::clear_timer(timer_id);
         }
         ic_cdk::spawn(sync_events(canister_id, events));

diff --git a/backend/canisters/user/impl/src/jobs/push_user_canister_events.rs b/backend/canisters/user/impl/src/jobs/push_user_canister_events.rs
@@ -22,7 +22,7 @@ pub(crate) fn start_job_if_required(state: &RuntimeState) -> bool {
 
 pub(crate) fn try_run_now_for_canister(state: &mut RuntimeState, canister_id: CanisterId) -> bool {
     if let Some(events) = state.data.user_canister_events_queue.try_start_for_canister(canister_id) {
-        if let Some(timer_id) = TIMER_ID.get() {
+        if let Some(timer_id) = TIMER_ID.take() {
             ic_cdk_timers::clear_timer(timer_id);
         }
         ic_cdk::spawn(process_batch(vec![(canister_id, events)]));

diff --git a/backend/canisters/user_index/impl/src/jobs/sync_events_to_local_user_index_canisters.rs b/backend/canisters/user_index/impl/src/jobs/sync_events_to_local_user_index_canisters.rs
@@ -22,7 +22,7 @@ pub(crate) fn start_job_if_required(state: &RuntimeState) -> bool {
 
 pub(crate) fn try_run_now(state: &mut RuntimeState) -> bool {
     if let Some(batch) = next_batch(state) {
-        if let Some(timer_id) = TIMER_ID.get() {
+        if let Some(timer_id) = TIMER_ID.take() {
             ic_cdk_timers::clear_timer(timer_id);
         }
         ic_cdk::spawn(process_batch(batch));

diff --git a/backend/canisters/user_index/impl/src/jobs/sync_users_to_storage_index.rs b/backend/canisters/user_index/impl/src/jobs/sync_users_to_storage_index.rs
@@ -22,7 +22,7 @@ pub(crate) fn start_job_if_required(state: &RuntimeState) -> bool {
 
 pub(crate) fn try_run_now(state: &mut RuntimeState) -> bool {
     if let Some((canister_id, users)) = next_batch(state) {
-        if let Some(timer_id) = TIMER_ID.get() {
+        if let Some(timer_id) = TIMER_ID.take() {
             ic_cdk_timers::clear_timer(timer_id);
         }
         ic_cdk::spawn(sync_users(canister_id, users));