From 37ed413a72cdc770f7d4bda574f22a16af22306d Mon Sep 17 00:00:00 2001 From: cyan Date: Wed, 9 Jul 2025 04:18:51 +0200 Subject: [PATCH] fix: make socket calls sync (#2363) --- cw_core/lib/utils/proxy_socket/abstract.dart | 4 ++-- cw_core/lib/utils/proxy_socket/insecure.dart | 4 ++-- cw_core/lib/utils/proxy_socket/secure.dart | 4 ++-- cw_core/lib/utils/proxy_socket/socks.dart | 4 ++-- 4 files changed, 8 insertions(+), 8 deletions(-) diff --git a/cw_core/lib/utils/proxy_socket/abstract.dart b/cw_core/lib/utils/proxy_socket/abstract.dart index b4b628f74..9c6019a5c 100644 --- a/cw_core/lib/utils/proxy_socket/abstract.dart +++ b/cw_core/lib/utils/proxy_socket/abstract.dart @@ -40,8 +40,8 @@ abstract class ProxySocket { } Future close(); - Future destroy(); - Future write(String data); + void destroy(); + void write(String data); StreamSubscription> listen(Function(Uint8List event) onData, {Function (Object error)? onError, Function ()? onDone, bool cancelOnError = true}); ProxyAddress get address; } \ No newline at end of file diff --git a/cw_core/lib/utils/proxy_socket/insecure.dart b/cw_core/lib/utils/proxy_socket/insecure.dart index aeac474d7..3ced63137 100644 --- a/cw_core/lib/utils/proxy_socket/insecure.dart +++ b/cw_core/lib/utils/proxy_socket/insecure.dart @@ -15,10 +15,10 @@ class ProxySocketInsecure implements ProxySocket { Future close() => socket.close(); @override - Future destroy() async => socket.destroy(); + void destroy() => socket.destroy(); @override - Future write(String data) async => socket.write(data); + void write(String data) => socket.write(data); @override StreamSubscription> listen(Function(Uint8List event) onData, {Function(Object error)? onError, Function()? onDone, bool cancelOnError = true}) { diff --git a/cw_core/lib/utils/proxy_socket/secure.dart b/cw_core/lib/utils/proxy_socket/secure.dart index 2efd13ee4..6ff287251 100644 --- a/cw_core/lib/utils/proxy_socket/secure.dart +++ b/cw_core/lib/utils/proxy_socket/secure.dart @@ -15,10 +15,10 @@ class ProxySocketSecure implements ProxySocket { Future close() => socket.close(); @override - Future destroy() async => socket.destroy(); + void destroy() => socket.destroy(); @override - Future write(String data) async => socket.write(data); + void write(String data) => socket.write(data); @override StreamSubscription> listen(Function(Uint8List event) onData, {Function(Object error)? onError, Function()? onDone, bool cancelOnError = true}) { diff --git a/cw_core/lib/utils/proxy_socket/socks.dart b/cw_core/lib/utils/proxy_socket/socks.dart index a4e5ddeb6..081e89c8d 100644 --- a/cw_core/lib/utils/proxy_socket/socks.dart +++ b/cw_core/lib/utils/proxy_socket/socks.dart @@ -16,10 +16,10 @@ class ProxySocketSocks implements ProxySocket { Future close() => socket.close(); @override - Future destroy() => close(); + void destroy() => close(); @override - Future write(String data) async => socket.write(data); + void write(String data) => socket.write(data); @override StreamSubscription> listen(Function(Uint8List event) onData, {Function(Object error)? onError, Function()? onDone, bool cancelOnError = true}) {