Merge pull request #23 from atsign-foundation/fix-socket-closed-while-other-side-still-writing

fix: socket closed while other side still writing

Author: gkc

lib/src/socket_connector.dart

@@ -141,17 +141,18 @@ class SocketConnector {
           StreamController<Uint8List> sc = StreamController<Uint8List>();
           side.farSide!.sink = sc;
           Stream<List<int>> transformed = side.transformer!(sc.stream);
-          transformed.listen((event) {
+          transformed.listen((event) async {
             try {
               side.farSide!.socket.add(event);
+              await side.farSide!.socket.flush();
             } catch (e) {
               _log('Failed to write to side ${side.farSide!.name} - closing',
                   force: true);
               _destroySide(side.farSide!);
             }
           });
         }
-        side.stream.listen((Uint8List data) {
+        side.stream.listen((Uint8List data) async {
           if (logTraffic) {
             final message = String.fromCharCodes(data);
             if (side.isSideA) {
@@ -164,6 +165,7 @@ class SocketConnector {
           }
           try {
             side.farSide!.sink.add(data);
+            await side.farSide!.socket.flush();
           } catch (e) {
             _log('Failed to write to side ${side.farSide!.name} - closing',
                 force: true);