Use debounceTime instead of throttleTime to avoid losing new messages
This commit is contained in:
@@ -69,21 +69,21 @@ class FcmMessageController extends FcmBaseController {
|
|||||||
void _listenForegroundMessageStream() {
|
void _listenForegroundMessageStream() {
|
||||||
FcmService.instance.foregroundMessageStreamController
|
FcmService.instance.foregroundMessageStreamController
|
||||||
?.stream
|
?.stream
|
||||||
.throttleTime(const Duration(milliseconds: FcmUtils.durationMessageComing))
|
.debounceTime(const Duration(milliseconds: FcmUtils.durationMessageComing))
|
||||||
.listen(_handleForegroundMessageAction);
|
.listen(_handleForegroundMessageAction);
|
||||||
}
|
}
|
||||||
|
|
||||||
void _listenBackgroundMessageStream() {
|
void _listenBackgroundMessageStream() {
|
||||||
FcmService.instance.backgroundMessageStreamController
|
FcmService.instance.backgroundMessageStreamController
|
||||||
?.stream
|
?.stream
|
||||||
.throttleTime(const Duration(milliseconds: FcmUtils.durationMessageComing))
|
.debounceTime(const Duration(milliseconds: FcmUtils.durationMessageComing))
|
||||||
.listen(_handleBackgroundMessageAction);
|
.listen(_handleBackgroundMessageAction);
|
||||||
}
|
}
|
||||||
|
|
||||||
void _listenTokenStream() {
|
void _listenTokenStream() {
|
||||||
FcmService.instance.fcmTokenStreamController
|
FcmService.instance.fcmTokenStreamController
|
||||||
?.stream
|
?.stream
|
||||||
.throttleTime(const Duration(milliseconds: FcmUtils.durationRefreshToken))
|
.debounceTime(const Duration(milliseconds: FcmUtils.durationRefreshToken))
|
||||||
.listen(FcmTokenController.instance.onFcmTokenChanged);
|
.listen(FcmTokenController.instance.onFcmTokenChanged);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user