11001588136

Committed 23 Sep 2024 08:06PM UTC coverage: 91.046% (-0.1%) from 91.185%

Build # 11001588136

Build Type

Pull #13

github

Committed by

MainRo

Commit Message

bump zstandard

Pull Request Pull Request #13: run: use CurrentThreadScheduler instead of NewThreadScheduler

Run Details

18 of 23 new or added lines in 1 file covered. (78.26%)

2176 of 2390 relevant lines covered (91.05%)

0.91 hits per line

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

80.0

/rxsci/run.py

import threading
import rx
from rx.scheduler import CurrentThreadScheduler


def run(pipe):
    exception = None
    latch = threading.Event()
    has_result = False
    result = None
    done = False

    def on_next(value):
        nonlocal result, has_result
        result = value
        has_result = True

    def on_error(error):
        nonlocal exception, done

        exception = error
        done = True
        latch.set()

    def on_completed() -> None:
        nonlocal done
        done = True
        latch.set()

    pipe.subscribe(on_next, on_error, on_completed, scheduler=CurrentThreadScheduler())

    while not done:
        latch.wait()

    if exception:
        raise exception

    return result

1	import threading	1✔
2	import rx	1✔
3	from rx.scheduler import CurrentThreadScheduler	1✔
4
5
6	def run(pipe):	1✔
7	exception = None	1✔
8	latch = threading.Event()	1✔
9	has_result = False	1✔
10	result = None	1✔
11	done = False	1✔
12
13	def on_next(value):	1✔
14	nonlocal result, has_result
15	result = value	1✔
16	has_result = True	1✔
17
18	def on_error(error):	1✔
19	nonlocal exception, done
20
NEW 21	exception = error	×
NEW 22	done = True	×
NEW 23	latch.set()	×
24
25	def on_completed() -> None:	1✔
26	nonlocal done
27	done = True	1✔
28	latch.set()	1✔
29
30	pipe.subscribe(on_next, on_error, on_completed, scheduler=CurrentThreadScheduler())	1✔
31
32	while not done:	1✔
NEW 33	latch.wait()	×
34
35	if exception:	1✔
NEW 36	raise exception	×
37
38	return result	1✔

maki-nage / rxsci / 11001588136

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