Skip to content

Commit f2226d5

Browse files
committed
Revert "Version 0.450.0."
This reverts commit 9ab6766.
1 parent 9ab6766 commit f2226d5

File tree

3 files changed

+3
-72
lines changed

3 files changed

+3
-72
lines changed
Lines changed: 0 additions & 69 deletions
Original file line numberDiff line numberDiff line change
@@ -1,71 +1,2 @@
1-
from fiber import Lock
2-
from fiber import Queue
3-
41
trait Message:
52
pass
6-
7-
class Bus:
8-
_subscribers: {i64: [Queue[Message]]}
9-
_lock: Lock
10-
11-
func __init__(self):
12-
self._subscribers = {}
13-
self._lock = Lock()
14-
15-
func subscribe(self, queue: Queue[Message], message_type: type):
16-
"""Subscribe to given message.
17-
18-
"""
19-
20-
self._lock.acquire()
21-
self._subscribers.get(message_type.id, [], True).append(queue)
22-
self._lock.release()
23-
24-
func broadcast(self, message: Message):
25-
"""Broadcast given message to all subscribers.
26-
27-
"""
28-
29-
self._lock.acquire()
30-
31-
for queue in self._subscribers.get(type(message).id, []):
32-
queue.put(message)
33-
34-
self._lock.release()
35-
36-
_BUS: Bus = Bus()
37-
38-
func subscribe(queue: Queue[Message], message_type: type):
39-
"""Subscribe to given message.
40-
41-
"""
42-
43-
_BUS.subscribe(queue, message_type)
44-
45-
func broadcast(message: Message):
46-
"""Broadcast given message to all subscribers.
47-
48-
"""
49-
50-
_BUS.broadcast(message)
51-
52-
class FooMessage(Message):
53-
pass
54-
55-
class BarMessage(Message):
56-
pass
57-
58-
func main():
59-
q1 = Queue[Message]()
60-
q2 = Queue[Message]()
61-
62-
subscribe(q1, FooMessage)
63-
subscribe(q1, BarMessage)
64-
subscribe(q2, BarMessage)
65-
66-
broadcast(FooMessage())
67-
broadcast(BarMessage())
68-
69-
assert q1.get() == FooMessage()
70-
assert q1.get() == BarMessage()
71-
assert q2.get() == BarMessage()

mys/lib/packages/fiber/src/lib.mys

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -207,8 +207,8 @@ class Lock:
207207
if self._waiters.length() > 0:
208208
resume(self._waiters.pop())
209209
else:
210-
self._is_acquired = False
211-
210+
self._is_acquired = False
211+
212212
class EventError(Error):
213213
message: string
214214

mys/version.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = '0.450.0'
1+
__version__ = '0.449.0'

0 commit comments

Comments
 (0)