504728006

Build Type

github

Committed by GitHub

Commit Message

<a href="https://github.com/ReactiveX/RxPY/commit/<a class=hub.com/ReactiveX/RxPY/commit/<a class="double-link" href="https://git"><a class=hub.com/ReactiveX/RxPY/commit/<a class="double-link" href="https://git"><a class=hub.com/ReactiveX/RxPY/commit/3d08cdebe69305337dcc87fdb89a10ec2cf10988">3d08cdebe<a href="https://github.com/ReactiveX/RxPY/commit/3d08cdebe69305337dcc87fdb89a10ec2cf10988">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/ReactiveX/RxPY/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/ReactiveX/RxPY/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/ReactiveX/RxPY/commit/3d08cdebe69305337dcc87fdb89a10ec2cf10988&quot;&gt;3d08cdebe&lt;/a&gt;&lt;a href=&quot;https://github.com/ReactiveX/RxPY/commit/3d08cdebe69305337dcc87fdb89a10ec2cf10988&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/ReactiveX/RxPY/commit/3d08cdebe69305337dcc87fdb89a10ec&lt;/a&gt;2cf10988">&quot;&gt;Merge &lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/ReactiveX/RxPY/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/ReactiveX/RxPY/commit/<a class="double-link" href="https://github.com/ReactiveX/RxPY/commit/939a40fe342e687f77346f5e0c3036a86b5a548d">939a40fe3</a><a href="https://github.com/ReactiveX/RxPY/commit/3d08cdebe69305337dcc87fdb89a10ec2cf10988">&amp;quot;&amp;gt;939a40fe3&amp;lt;/a&amp;gt;&amp;quot;&amp;gt;939a40fe3&amp;lt;/a&amp;gt;&amp;lt;a href=&amp;quot;https://github.com/ReactiveX/RxPY/commit/3d08cdebe69305337dcc87fdb89a10ec2cf10&lt;/a&gt;988&quot;&gt; into &lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/ReactiveX/RxPY/commit/<a class="double-link" href="https://github.com/ReactiveX/RxPY/commit/24f3c2d63">24f3c2d63">24f3c2d63</a>

Pull Request Pull Request #550: [WIP] fix github actions

Run Details

27 of 27 new or added lines in 8 files covered. (100.0%)

22559 of 24131 relevant lines covered (93.49%)

0.93 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

25.0

/tests/test_scheduler/test_mainloop/test_tkinterscheduler.py

import pytest
import unittest

from datetime import timedelta
from time import sleep

from rx.scheduler.mainloop import TkinterScheduler
from rx.internal.basic import default_now


tkinter = pytest.importorskip("tkinter")

try:
    root = tkinter.Tk()
    root.withdraw() # Don't actually draw anything
    display = True
except Exception:
    display = False


@pytest.mark.skipif("display == False")
class TestTkinterScheduler(unittest.TestCase):

    def test_tkinter_schedule_now(self):
        scheduler = TkinterScheduler(root)
        res = scheduler.now - default_now()
        assert abs(res) <= timedelta(milliseconds=1)

    def test_tkinter_schedule_now_units(self):
        scheduler = TkinterScheduler(root)
        diff = scheduler.now
        sleep(1.1)
        diff = scheduler.now - diff
        assert timedelta(milliseconds=1000) < diff < timedelta(milliseconds=1300)

    def test_tkinter_schedule_action(self):
        scheduler = TkinterScheduler(root)
        ran = False

        def action(scheduler, state):
            nonlocal ran
            ran = True

        scheduler.schedule(action)

        def done():
            assert ran is True
            root.quit()

        root.after_idle(done)
        root.mainloop()

    def test_tkinter_schedule_action_due(self):
        scheduler = TkinterScheduler(root)
        starttime = default_now()
        endtime = None

        def action(scheduler, state):
            nonlocal endtime
            endtime = default_now()

        scheduler.schedule_relative(0.2, action)

        def done():
            root.quit()
            assert endtime is not None
            diff = endtime - starttime
            assert diff > timedelta(milliseconds=180)

        root.after(300, done)
        root.mainloop()

    def test_tkinter_schedule_action_cancel(self):
        ran = False
        scheduler = TkinterScheduler(root)

        def action(scheduler, state):
            nonlocal ran
            ran = True

        d = scheduler.schedule_relative(0.1, action)
        d.dispose()

        def done():
            root.quit()
            assert ran is False

        root.after(300, done)
        root.mainloop()

    def test_tkinter_schedule_action_periodic(self):
        scheduler = TkinterScheduler(root)
        period = 0.050
        counter = 3

        def action(state):
            nonlocal counter
            if state:
                counter -= 1
                return state - 1

        scheduler.schedule_periodic(period, action, counter)

        def done():
            root.quit()
            assert counter == 0

        root.after(300, done)
        root.mainloop()

1	import pytest	1✔
2	import unittest	1✔
3
4	from datetime import timedelta	1✔
5	from time import sleep	1✔
6
7	from rx.scheduler.mainloop import TkinterScheduler	1✔
8	from rx.internal.basic import default_now	1✔
9
10
11	tkinter = pytest.importorskip("tkinter")	1✔
12
13	try:	1✔
14	root = tkinter.Tk()	1✔
15	root.withdraw() # Don't actually draw anything	×
16	display = True	×
17	except Exception:	1✔
18	display = False	1✔
19
20
21	@pytest.mark.skipif("display == False")	1✔
22	class TestTkinterScheduler(unittest.TestCase):	1✔
23
24	def test_tkinter_schedule_now(self):	1✔
25	scheduler = TkinterScheduler(root)	×
26	res = scheduler.now - default_now()	×
27	assert abs(res) <= timedelta(milliseconds=1)	×
28
29	def test_tkinter_schedule_now_units(self):	1✔
30	scheduler = TkinterScheduler(root)	×
31	diff = scheduler.now	×
32	sleep(1.1)	×
33	diff = scheduler.now - diff	×
34	assert timedelta(milliseconds=1000) < diff < timedelta(milliseconds=1300)	×
35
36	def test_tkinter_schedule_action(self):	1✔
37	scheduler = TkinterScheduler(root)	×
38	ran = False	×
39
40	def action(scheduler, state):	×
41	nonlocal ran
42	ran = True	×
43
44	scheduler.schedule(action)	×
45
46	def done():	×
47	assert ran is True	×
48	root.quit()	×
49
50	root.after_idle(done)	×
51	root.mainloop()	×
52
53	def test_tkinter_schedule_action_due(self):	1✔
54	scheduler = TkinterScheduler(root)	×
55	starttime = default_now()	×
56	endtime = None	×
57
58	def action(scheduler, state):	×
59	nonlocal endtime
60	endtime = default_now()	×
61
62	scheduler.schedule_relative(0.2, action)	×
63
64	def done():	×
65	root.quit()	×
66	assert endtime is not None	×
67	diff = endtime - starttime	×
68	assert diff > timedelta(milliseconds=180)	×
69
70	root.after(300, done)	×
71	root.mainloop()	×
72
73	def test_tkinter_schedule_action_cancel(self):	1✔
74	ran = False	×
75	scheduler = TkinterScheduler(root)	×
76
77	def action(scheduler, state):	×
78	nonlocal ran
79	ran = True	×
80
81	d = scheduler.schedule_relative(0.1, action)	×
82	d.dispose()	×
83
84	def done():	×
85	root.quit()	×
86	assert ran is False	×
87
88	root.after(300, done)	×
89	root.mainloop()	×
90
91	def test_tkinter_schedule_action_periodic(self):	1✔
92	scheduler = TkinterScheduler(root)	×
93	period = 0.050	×
94	counter = 3	×
95
96	def action(state):	×
97	nonlocal counter
98	if state:	×
99	counter -= 1	×
100	return state - 1	×
101
102	scheduler.schedule_periodic(period, action, counter)	×
103
104	def done():	×
105	root.quit()	×
106	assert counter == 0	×
107
108	root.after(300, done)	×
109	root.mainloop()	×

ReactiveX / RxPY / 504728006

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous