| .. | .. |
|---|
| 267 | 267 | } |
|---|
| 268 | 268 | } |
|---|
| 269 | 269 | |
|---|
| 270 | | - void _handleIncomingMessage(Map<String, dynamic> msg) { |
|---|
| 270 | + Future<void> _handleIncomingMessage(Map<String, dynamic> msg) async { |
|---|
| 271 | 271 | final sessionId = msg['sessionId'] as String?; |
|---|
| 272 | 272 | final content = msg['content'] as String? ?? |
|---|
| 273 | 273 | msg['text'] as String? ?? |
|---|
| .. | .. |
|---|
| 282 | 282 | final activeId = ref.read(activeSessionIdProvider); |
|---|
| 283 | 283 | if (sessionId != null && sessionId != activeId) { |
|---|
| 284 | 284 | // Store message for the other session so it's there when user switches |
|---|
| 285 | | - _storeForSession(sessionId, message); |
|---|
| 285 | + await _storeForSession(sessionId, message); |
|---|
| 286 | 286 | _incrementUnread(sessionId); |
|---|
| 287 | 287 | final sessions = ref.read(sessionsProvider); |
|---|
| 288 | 288 | final session = sessions.firstWhere( |
|---|
| .. | .. |
|---|
| 347 | 347 | |
|---|
| 348 | 348 | final activeId = ref.read(activeSessionIdProvider); |
|---|
| 349 | 349 | if (sessionId != null && sessionId != activeId) { |
|---|
| 350 | | - _storeForSession(sessionId, storedMessage); |
|---|
| 350 | + await _storeForSession(sessionId, storedMessage); |
|---|
| 351 | 351 | _incrementUnread(sessionId); |
|---|
| 352 | 352 | final sessions = ref.read(sessionsProvider); |
|---|
| 353 | 353 | final session = sessions.firstWhere( |
|---|
