@@ -274,7 +274,7 @@ class PerAccountStore extends ChangeNotifier with ChannelStore, MessageStore {
274
274
assert (realmUrl == globalStore.getAccount (accountId)! .realmUrl),
275
275
assert (realmUrl == connection.realmUrl),
276
276
_globalStore = globalStore,
277
- _streams = channels,
277
+ _channels = channels,
278
278
_messages = messages;
279
279
280
280
////////////////////////////////////////////////////////////////
@@ -320,22 +320,22 @@ class PerAccountStore extends ChangeNotifier with ChannelStore, MessageStore {
320
320
final Map <int , User > users;
321
321
322
322
////////////////////////////////
323
- // Streams , topics, and stuff about them.
323
+ // Channels , topics, and stuff about them.
324
324
325
325
@override
326
- Map <int , Channel > get channels => _streams .channels;
326
+ Map <int , Channel > get channels => _channels .channels;
327
327
@override
328
- Map <String , Channel > get channelsByName => _streams .channelsByName;
328
+ Map <String , Channel > get channelsByName => _channels .channelsByName;
329
329
@override
330
- Map <int , Subscription > get subscriptions => _streams .subscriptions;
330
+ Map <int , Subscription > get subscriptions => _channels .subscriptions;
331
331
@override
332
332
UserTopicVisibilityPolicy topicVisibilityPolicy (int channelId, String topic) =>
333
- _streams .topicVisibilityPolicy (channelId, topic);
333
+ _channels .topicVisibilityPolicy (channelId, topic);
334
334
335
- final ChannelStoreImpl _streams ;
335
+ final ChannelStoreImpl _channels ;
336
336
337
337
@visibleForTesting
338
- ChannelStoreImpl get debugStreamStore => _streams ;
338
+ ChannelStoreImpl get debugStreamStore => _channels ;
339
339
340
340
////////////////////////////////
341
341
// Messages, and summaries of messages.
@@ -456,15 +456,15 @@ class PerAccountStore extends ChangeNotifier with ChannelStore, MessageStore {
456
456
notifyListeners ();
457
457
} else if (event is StreamEvent ) {
458
458
assert (debugLog ("server event: stream/${event .op }" ));
459
- _streams .handleChannelEvent (event);
459
+ _channels .handleChannelEvent (event);
460
460
notifyListeners ();
461
461
} else if (event is SubscriptionEvent ) {
462
462
assert (debugLog ("server event: subscription/${event .op }" ));
463
- _streams .handleSubscriptionEvent (event);
463
+ _channels .handleSubscriptionEvent (event);
464
464
notifyListeners ();
465
465
} else if (event is UserTopicEvent ) {
466
466
assert (debugLog ("server event: user_topic" ));
467
- _streams .handleUserTopicEvent (event);
467
+ _channels .handleUserTopicEvent (event);
468
468
notifyListeners ();
469
469
} else if (event is MessageEvent ) {
470
470
assert (debugLog ("server event: message ${jsonEncode (event .message .toJson ())}" ));
0 commit comments