fix broadcast
This commit is contained in:
parent
c5d56a2604
commit
ecf921f91e
1 changed files with 3 additions and 5 deletions
|
@ -30,12 +30,10 @@ public class NetDiscoverer {
|
||||||
public void discoverActiveUsers(String broadcastMessage, ResponseReceivedCallback callback, ErrorCallback errorCallback) {
|
public void discoverActiveUsers(String broadcastMessage, ResponseReceivedCallback callback, ErrorCallback errorCallback) {
|
||||||
if (responseListener != null)
|
if (responseListener != null)
|
||||||
responseListener.stopListening();
|
responseListener.stopListening();
|
||||||
responseListener = new ResponseListener((ipAddr, data) -> {
|
responseListener = new ResponseListener(callback, errorCallback);
|
||||||
|
responseListener.start();
|
||||||
broadcastSender = new BroadcastSender(broadcastMessage, errorCallback);
|
broadcastSender = new BroadcastSender(broadcastMessage, errorCallback);
|
||||||
broadcastSender.start();
|
broadcastSender.start();
|
||||||
callback.onResponseReceived(ipAddr, data);
|
|
||||||
}, errorCallback);
|
|
||||||
responseListener.start();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
Loading…
Reference in a new issue