int get limit => _limit;
set limit(int limit) { _limit = limit; if (_sub != null) { if (!limited || _counter < limit) { _sub.resume(); } else { _sub.pause(); } } }