close method

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

Close the specified channels.

Implementation

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);
}