mirror of
https://github.com/localsend/localsend.git
synced 2026-06-23 04:10:07 +00:00
deps: bump flutter from 3.24.5 to 3.32.8
This commit is contained in:
@@ -268,7 +268,7 @@ Stream<R> _sendTaskAndListenStream<R, T>({
|
||||
data: task,
|
||||
);
|
||||
|
||||
// ignore: unawaited_futures
|
||||
// ignore: discarded_futures
|
||||
Future.microtask(() {
|
||||
connection.sendToIsolate(SendToIsolateData<IsolateTask<T>>(
|
||||
syncState: null,
|
||||
|
||||
@@ -65,6 +65,7 @@ class MulticastService {
|
||||
streamController.add(peer);
|
||||
if ((dto.announcement == true || dto.announce == true) && syncState.serverRunning) {
|
||||
// only respond when server is running
|
||||
// ignore: discarded_futures
|
||||
_answerAnnouncement(peer);
|
||||
}
|
||||
} catch (e) {
|
||||
@@ -83,6 +84,7 @@ class MulticastService {
|
||||
|
||||
// ignore: unawaited_futures
|
||||
_cancelCompleter.future.then((_) {
|
||||
// ignore: discarded_futures
|
||||
streamController.close();
|
||||
for (final socket in sockets) {
|
||||
socket.socket.close();
|
||||
|
||||
@@ -48,6 +48,7 @@ class TaskRunner<T> {
|
||||
onFinish: () {
|
||||
_runnerCount--;
|
||||
if (_stopped || (_runnerCount == 0 && !_stayAlive)) {
|
||||
// ignore: discarded_futures
|
||||
_streamController.close();
|
||||
onFinish?.call();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user