|
|
@ -567,9 +567,11 @@ class SessionManager(object): |
|
|
|
for hashX in set(hc).intersection(touched): |
|
|
|
del hc[hashX] |
|
|
|
|
|
|
|
async with TaskGroup() as group: |
|
|
|
for session in self.sessions: |
|
|
|
await group.spawn(session.notify(touched, height_changed)) |
|
|
|
# FIXME |
|
|
|
async with ignore_after(15): |
|
|
|
async with TaskGroup() as group: |
|
|
|
for session in self.sessions: |
|
|
|
await group.spawn(session.notify(touched, height_changed)) |
|
|
|
|
|
|
|
def add_session(self, session): |
|
|
|
self.sessions.add(session) |
|
|
|