Check if an Rx stream is registered for testing
@visibleForTesting bool hasStream(int id) => _subs[id] != null;