Future<void> disconnectAndUpdateStream({bool queue = true}) async { _dstream.add(true); try { await disconnect(queue: queue); } finally { _dstream.add(false); } }