Source
Stream<String> discover({Duration timeout: const Duration(seconds: 5)}) { _send("DISCOVER", "239.255.255.230", 1900); Stream<String> stream = _brokerController.stream; new Future.delayed(timeout, () { close(); }); return stream; }
Stream<String> discover({Duration timeout: const Duration(seconds: 5)}) { _send("DISCOVER", "239.255.255.230", 1900); Stream<String> stream = _brokerController.stream; new Future.delayed(timeout, () { close(); }); return stream; }