svich-hcss
diff --git a/‎examples/client/asyncio/latency_client.py‎
Lines changed: 11 additions & 4 deletions b/‎examples/client/asyncio/latency_client.py‎
Lines changed: 11 additions & 4 deletions
diff --git a/‎examples/client/asyncio/received.txt‎
Lines changed: 1 addition & 0 deletions b/‎examples/client/asyncio/received.txt‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎examples/server/aiohttp/latency.py‎
Lines changed: 6 additions & 2 deletions b/‎examples/server/aiohttp/latency.py‎
Lines changed: 6 additions & 2 deletions
diff --git a/‎examples/server/aiohttp/test.jpg‎
2.48 MB b/‎examples/server/aiohttp/test.jpg‎
2.48 MB
@@ -2,6 +2,8 @@
 import time
 import socketio
 
+IMG_PATH='received.txt'
+
 loop = asyncio.get_event_loop()
 sio = socketio.AsyncClient()
 start_timer = None
@@ -20,16 +22,21 @@ async def connect():
 
 
 @sio.event
-async def pong_from_server():
+async def pong_from_server(data):
+    print('Received pong from server.')
     global start_timer
-    latency = time.time() - start_timer
-    print('latency is {0:.2f} ms'.format(latency * 1000))
+    # print(data)
+    # latency = time.time() - start_timer
+    # print('latency is {0:.2f} ms'.format(latency * 1000))
+    image_data = data['image_data']
+    with open(IMG_PATH, 'wb') as file:
+        file.write(image_data)
     await sio.sleep(1)
     await send_ping()
 
 
 async def start_server():
-    await sio.connect('http://localhost:5000')
+    await sio.connect('http://localhost:8080')
     await sio.wait()
 
 
 
@@ -1,6 +1,9 @@
 from aiohttp import web
 
 import socketio
+import base64
+
+IMG_PATH = 'test.jpg'
 
 sio = socketio.AsyncServer(async_mode='aiohttp', cors_allowed_origins='*')
 app = web.Application()
@@ -11,10 +14,11 @@ async def index(request):
     with open('latency.html') as f:
         return web.Response(text=f.read(), content_type='text/html')
 
-
 @sio.event
 async def ping_from_client(sid):
-    await sio.emit('pong_from_server', room=sid)
+    with open(IMG_PATH, 'rb') as file:
+        image_data = base64.b64encode(file.read())
+    await sio.emit('pong_from_server', {'image_data': image_data}, room=sid)
 
 @sio.event
 async def connect(sid, environment):