From bcfc4fe3baa94bc054f949e65389e05969b7ff50 Mon Sep 17 00:00:00 2001 From: eunhhu Date: Sun, 4 Oct 2026 16:20:17 +0100 Subject: Wake each thread at most once a push, end streams only of stopped apps, and show a subscriber costs writes nothing (019) --- tests/check.py | 8 ++++++++ 1 file changed, 8 insertions(+) (limited to 'tests') diff --git a/tests/check.py b/tests/check.py index 91aec12..f599fb6 100644 --- a/tests/check.py +++ b/tests/check.py @@ -4723,6 +4723,14 @@ def server_push(aup, pure, work): write(work / 'push-gone.pmod') reading() assert stream.ends(), 'a stream of a view that went still runs' + write(module) + reading() + stream = EventStream(host.port, '/p/views/total', token=token) + assert stream.next()[2] == '2' + conf.write_text(f"q {module} {work / 'push-q'}\n") # p goes: its streams end + said = reading() + assert {app['name']: app['did'] for app in said['apps']}['p'] == 'removed', said + assert stream.ends(), 'a stream of an app that went still runs' finally: stats = host.stop() assert stats[0]['subscribers'] == 0, stats[0] -- cgit v1.2.3