Nexus/nexus
Nexus/nexus
4
4
Fork 5
Code Issues 6 Pull requests Projects Releases Packages Wiki Activity

Revert "temp isolate"

Browse source 
This reverts commit 34e6c07d8d.
This commit is contained in:
Henry Hiles 2026-05-21 12:16:07 -04:00
commit 57cfad9f45
Signed by: Henry-Hiles
SSH key fingerprint: SHA256:VKQUdS31Q90KvX7EkKMHMBpUspcmItAh86a+v7PGiIs
1 changed files with 10 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

16
lib/controllers/rooms_controller.dart
View file

@ -1,5 +1,3 @@
import "dart:isolate";
import "package:fast_immutable_collections/fast_immutable_collections.dart"; import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/models/event.dart"; import "package:nexus/models/event.dart";
@ -40,11 +38,7 @@ class RoomsController extends Notifier<IMap<String, Room>> {
); );
Future<void> update(IMap<String, Room> rooms, ISet<String> leftRooms) async { Future<void> update(IMap<String, Room> rooms, ISet<String> leftRooms) async {
final merged = await rooms.entries.fold(Future.sync(() => state), ( final merged = rooms.entries.fold(state, (acc, entry) {
accF,
entry,
) async {
final acc = await accF;
final roomId = entry.key; final roomId = entry.key;
final incoming = entry.value; final incoming = entry.value;
final existing = acc[roomId]; final existing = acc[roomId];
@ -57,8 +51,7 @@ class RoomsController extends Notifier<IMap<String, Room>> {
events: incoming.events.isEmpty events: incoming.events.isEmpty
? existing.events ? existing.events
: existing.events.addAll(incoming.events), : existing.events.addAll(incoming.events),
state: await Isolate.run(() { state: incoming.state.entries.fold(
final state = incoming.state.entries.fold(
existing.state, existing.state,
(previousValue, event) => previousValue.add( (previousValue, event) => previousValue.add(
event.key, event.key,
@ -66,9 +59,7 @@ class RoomsController extends Notifier<IMap<String, Room>> {
event.value, event.value,
), ),
), ),
); ),
return state;
}),
reset: false, reset: false,
hasFetchedMembers: hasFetchedMembers:
incoming.hasFetchedMembers || existing.hasFetchedMembers, incoming.hasFetchedMembers || existing.hasFetchedMembers,
@ -95,6 +86,7 @@ class RoomsController extends Notifier<IMap<String, Room>> {
merged, merged,
(acc, roomId) => acc.remove(roomId), (acc, roomId) => acc.remove(roomId),
); );
state = prunedList; state = prunedList;
} }