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
|
#!/usr/bin/env python3
import pykka
GetMessages = object()
class PlainActor(pykka.ThreadingActor):
def __init__(self):
super().__init__()
self.stored_messages = []
def on_receive(self, message):
if message is GetMessages:
return self.stored_messages
self.stored_messages.append(message)
return None
if __name__ == "__main__":
actor = PlainActor.start()
actor.tell({"no": "Norway", "se": "Sweden"})
actor.tell({"a": 3, "b": 4, "c": 5})
print(actor.ask(GetMessages))
actor.stop()
|
