Skip to content

Commit 57a42df

Browse files
committed
[FIX/#248] collect -> first 변경으로 DB 변경 시 반복 등록되는 버그 수정
1 parent a0721fd commit 57a42df

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

core/alarm/src/main/java/com/yapp/alarm/receivers/RescheduleAlarmReceiver.kt

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ import com.yapp.domain.usecase.AlarmUseCase
88
import dagger.hilt.android.AndroidEntryPoint
99
import kotlinx.coroutines.CoroutineScope
1010
import kotlinx.coroutines.Dispatchers
11+
import kotlinx.coroutines.flow.first
1112
import kotlinx.coroutines.launch
1213
import javax.inject.Inject
1314

@@ -31,11 +32,10 @@ class RescheduleAlarmReceiver : BroadcastReceiver() {
3132

3233
private fun rescheduleAlarm() {
3334
CoroutineScope(Dispatchers.IO).launch {
34-
alarmUseCase.getAllAlarms().collect { alarms ->
35-
alarms.forEach { alarm ->
36-
androidAlarmScheduler.scheduleAlarm(alarm)
37-
}
38-
}
35+
val alarms = alarmUseCase.getAllAlarms().first()
36+
alarms
37+
.filter { it.isAlarmActive }
38+
.forEach { alarm -> androidAlarmScheduler.scheduleAlarm(alarm) }
3939
}
4040
}
4141
}

0 commit comments

Comments
 (0)