blob: 70a4d226bae9883eb6aa269bf37b1385f62bc087 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
import aiogreen
from aiogreen import socketpair
# Create a pair of connected file descriptors
rsock, wsock = socketpair()
loop = aiogreen.EventLoop()
def reader():
data = rsock.recv(100)
print("Received: %s" % data.decode())
# We are done: unregister the file descriptor
loop.remove_reader(rsock)
# Stop the event loop
loop.stop()
def writer():
loop.remove_writer(wsock)
# Simulate the reception of data from the network
print("Send: abc")
loop.call_soon(wsock.send, 'abc'.encode())
# Register the file descriptor for read event
loop.add_reader(rsock, reader)
loop.add_writer(wsock, writer)
# Run the event loop
loop.run_forever()
# We are done, close sockets and the event loop
rsock.close()
wsock.close()
loop.close()
|
