Stream<BrokerDiscoverRequest> requests

Source 

Stream<BrokerDiscoverRequest> get requests => _discoverController.stream;