close method

@override void close({ Iterable<String> channels = const [""], })

Close the specified channels. All the connections with the subscribers to this channels will be closed. By default only closes the default channel.

Implementation

@override
void close({Iterable<String> channels: const [""]}) {
  for (String channel in channels) {
    List<ProxySink>? subs = _subsByChannel[channel];
    if (subs == null) {
      continue;
    }
    _logInfo("Closing channel $channel with ${subs.length} subscribers.");
    for (var sub in subs) {
      sub.close();
    }
  }
  _cache?.clear(channels);
}