Wake each thread at most once a push, end streams only of stopped apps, and show a subscriber costs writes nothing (019)

1 files changed, 8 insertions, 0 deletions

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]