505779028

Build Type

github

Committed by GitHub

Commit Message

<a href="https://github.com/ReactiveX/RxPY/commit/<a class=hub.com/ReactiveX/RxPY/commit/41d80d4598426722b4b34d35f08c9a26084d56b1">41d80d459<a href="https://github.com/ReactiveX/RxPY/commit/41d80d4598426722b4b34d35f08c9a26084d56b1">">Merge </a><a class="double-link" href="https://github.com/ReactiveX/RxPY/commit/<a class="double-link" href="https://github.com/ReactiveX/RxPY/commit/a53a29a0012414488bec027e3b17fc8c581b33c5">a53a29a00</a>">a53a29a00</a><a href="https://github.com/ReactiveX/RxPY/commit/41d80d4598426722b4b34d35f08c9a26084d56b1"> into 24f3c2d63">24f3c2d63</a>

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

Run Details

31 of 31 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 / 505779028

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