subscribeLocal method

LocalSubscription subscribeLocal(
  1. List<TagValue> filterTags
)

In-process subscription: events fan out to it exactly like an RPC subscriber, without a call. Useful embedded and for tests; close() unregisters.

Implementation

LocalSubscription subscribeLocal(List<TagValue> filterTags) {
  final sub = _Subscriber(filterTags, queueCapacity);
  _subscribers.add(sub);
  return LocalSubscription._(this, sub);
}