ReactiveX/RxPY

Pattern Findings

The scanner identified 1792 distinct pattern matches across 15 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.

Docstring Block Structure293 hits · 1365 pts

Severity	File	Line	Snippet	Context
HIGH	reactivex/run.py	16	Run source synchronously. Subscribes to the observable source. Then blocks and waits for the observable source	STRING
HIGH	reactivex/notification.py	29	Invokes the delegate corresponding to the notification or an observer and returns the produced result.	STRING
HIGH	reactivex/__init__.py	68	Uses mapper to determine which source in sources to use. .. marble:: :alt: case --1---------------	STRING
HIGH	reactivex/__init__.py	102	Continues observable sequences which are terminated with an exception by switching over to the next observable seque	STRING
HIGH	reactivex/__init__.py	130	Continues observable sequences that are terminated with an exception by switching over to the next observable sequen	STRING
HIGH	reactivex/__init__.py	203	Merges the specified observable sequences into one observable sequence by creating a tuple whenever any of the obser	STRING
HIGH	reactivex/__init__.py	235	Concatenates all of the specified observable sequences. .. marble:: :alt: concat ---1--2--3--\|	STRING
HIGH	reactivex/__init__.py	262	Concatenates all of the specified observable sequences. .. marble:: :alt: concat ---1--2--3--\|	STRING
HIGH	reactivex/__init__.py	414	Wait for observables to complete and then combine last values they emitted into a tuple. Whenever any of that observ	STRING
HIGH	reactivex/__init__.py	446	Returns an observable sequence that contains a single element generated by the given supplier, using the specified s	STRING
HIGH	reactivex/__init__.py	566	Convert a marble diagram string to a cold observable sequence, using an optional scheduler to enumerate the events.	STRING
HIGH	reactivex/__init__.py	712	Convert a marble diagram string to a hot observable sequence, using an optional scheduler to enumerate the events.	STRING
HIGH	reactivex/__init__.py	785	Determines whether an observable collection contains values. .. marble:: :alt: if_then ---1--2--3-	STRING
HIGH	reactivex/__init__.py	926	Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.	STRING
HIGH	reactivex/__init__.py	960	Generates an observable sequence of integral numbers within a specified range, using the specified scheduler to send	STRING
HIGH	reactivex/__init__.py	997	Returns an observable sequence that contains a single element, using the specified scheduler to send out observer me	STRING
HIGH	reactivex/__init__.py	1026	Generates an observable sequence that repeats the given element the specified number of times. .. marble::	STRING
HIGH	reactivex/__init__.py	1148	Returns an observable sequence that produces a value after duetime has elapsed and then after each period. .. m	STRING
HIGH	reactivex/__init__.py	1186	Converts the function into an asynchronous function. Each invocation of the resulting asynchronous function causes a	STRING
HIGH	reactivex/__init__.py	1242	Merges the specified observable sequences into one observable sequence by creating a :class:`tuple` only when the fi	STRING
HIGH	reactivex/operators/_timeinterval.py	24	Records the time interval between consecutive values in an observable sequence. Examples: >>> res = sou	STRING
HIGH	reactivex/operators/_sum.py	14	Computes the sum of a sequence of values. Examples: >>> result = source.pipe(sum()) >>> result = su	STRING
HIGH	reactivex/operators/_takelastwithtime.py	16	Returns elements within the specified duration from the end of the observable source sequence. Examples:	STRING
HIGH	reactivex/operators/_subscribeon.py	19	Subscribe on the specified scheduler. Wrap the source sequence in order to run its subscription and unsubscript	STRING
HIGH	reactivex/operators/_expand.py	20	Expands an observable sequence by recursively invoking mapper. Examples: >>> source.pipe(expand(lambda	STRING
HIGH	reactivex/operators/_minby.py	66	The `min_by` operator. Returns the elements in an observable sequence with the minimum key value according to t	STRING
HIGH	reactivex/operators/_asobservable.py	11	Hides the identity of an observable sequence. Examples: >>> res = source.pipe(as_observable()) >>>	STRING
HIGH	reactivex/operators/_isempty.py	12	Determines whether an observable sequence is empty. Examples: >>> res = source.pipe(is_empty()) >>>	STRING
HIGH	reactivex/operators/_windowwithcount.py	20	Projects each element of an observable sequence into zero or more windows which are produced based on element count	STRING
HIGH	reactivex/operators/_maxby.py	20	Partially applied max_by operator. Returns the elements in an observable sequence with the maximum key	STRING
HIGH	reactivex/operators/_todict.py	18	Converts the observable sequence to a dictionary. Examples: >>> result = source.pipe(to_dict(lambda x: x.id	STRING
HIGH	reactivex/operators/_skipuntilwithtime.py	17	Skips elements from the observable source sequence until the specified start time. Errors produced by t	STRING
HIGH	reactivex/operators/_takewithtime.py	17	Takes elements for the specified duration from the start of the observable source sequence. Examples: >	STRING
HIGH	reactivex/operators/_distinct.py	38	Returns an observable sequence that contains only distinct elements. Returns an observable sequence that contains o	STRING
HIGH	reactivex/operators/_withlatestfrom.py	13	With latest from operator. Merges the specified observable sequences into one observable sequence by creating a	STRING
HIGH	reactivex/operators/_takeuntil.py	16	Returns the values from the source observable sequence until the other observable sequence produces a value. Ex	STRING
HIGH	reactivex/operators/_ignoreelements.py	11	Ignores all elements in an observable sequence leaving only the termination messages. Examples: >>> res	STRING
HIGH	reactivex/operators/_delaysubscription.py	17	Time shifts the observable sequence by delaying the subscription. Examples: >>> source.pipe(delay_subscript	STRING
HIGH	reactivex/operators/_switchlatest.py	19	Transforms an observable sequence of observable sequences into an observable sequence producing values only from the	STRING
HIGH	reactivex/operators/_takewhile.py	16	Returns elements from an observable sequence as long as a specified condition is true. Examples: >>> re	STRING
HIGH	reactivex/operators/_takewhile.py	74	Returns elements from an observable sequence as long as a specified condition is true. The element's index is used i	STRING
HIGH	reactivex/operators/_windowwithtime.py	25	Projects each element of an observable sequence into zero or more windows which are produced based on timing informa	STRING
HIGH	reactivex/operators/_dematerialize.py	11	Dematerializes the explicit notification values of an observable sequence as implicit notifications. Examples:	STRING
HIGH	reactivex/operators/_exclusive.py	14	Performs a exclusive waiting for the first to finish before subscribing to another observable. Observables that come	STRING
HIGH	reactivex/operators/_forkjoin.py	13	Wait for observables to complete and then combine last values they emitted into a tuple. Whenever any of that observ	STRING
HIGH	reactivex/operators/_defaultifempty.py	14	Returns the elements of the specified sequence or the specified value in a singleton sequence if the sequence is	STRING
HIGH	reactivex/operators/_delaywithmapper.py	21	Time shifts the observable sequence based on a subscription delay and a delay mapper function for each element.	STRING
HIGH	reactivex/operators/_last.py	17	Returns the last element of an observable sequence that satisfies the condition in the predicate if specified, else	STRING
HIGH	reactivex/operators/_take.py	11	Returns a specified number of contiguous elements from the start of an observable sequence. Example: >>	STRING
HIGH	reactivex/operators/_throttlefirst.py	17	Returns an observable that emits only the first item emitted by the source Observable during sequential time windows	STRING
HIGH	reactivex/operators/_min.py	26	Returns the minimum element in an observable sequence. Returns the minimum element in an observable sequence accord	STRING
HIGH	reactivex/operators/_sample.py	60	Samples the observable sequence at each interval. Examples: >>> res = source.pipe(sample(1.0)) >>>	STRING
HIGH	reactivex/operators/_elementatordefault.py	17	Returns the element at a specified index in a sequence or a default value if the index is out of range. Example	STRING
HIGH	reactivex/operators/_buffer.py	16	Buffers elements from the source based on boundary notifications. Examples: >>> res = source.pipe(buffer(bo	STRING
HIGH	reactivex/operators/_buffer.py	40	Buffers elements using a closing mapper function. Examples: >>> res = source.pipe(buffer_when(lambda: timer	STRING
HIGH	reactivex/operators/_buffer.py	65	Buffers elements using opening/closing observables. Examples: >>> res = source.pipe(buffer_toggle(opens, la	STRING
HIGH	reactivex/operators/_buffer.py	91	Projects each element of an observable sequence into zero or more buffers which are produced based on element count	STRING
HIGH	reactivex/operators/_sequenceequal.py	22	Determines whether two sequences are equal by comparing the elements pairwise using a specified equality compare	STRING
HIGH	reactivex/operators/_windowwithtimeorcount.py	24	Projects each element of an observable sequence into zero or more windows which are produced based on timing informa	STRING
HIGH	reactivex/operators/_find.py	16	Searches for an element in an observable sequence. Examples: >>> res = source.pipe(find_value(lambda x, i,	STRING
233 more matches not shown…

Hyper-Verbose Identifiers967 hits · 974 pts

Severity	File	Line	Snippet	Context
LOW	tests/test_disposables/test_disposable.py	46	def test_future_disposable_setnone():	CODE
LOW	tests/test_disposables/test_disposable.py	52	def test_futuredisposable_disposeafterset():	CODE
LOW	tests/test_disposables/test_disposable.py	70	def test_futuredisposable_disposebeforeset():	CODE
LOW	tests/test_disposables/test_disposable.py	89	def test_groupdisposable_contains():	CODE
LOW	tests/test_disposables/test_disposable.py	113	def test_groupdisposable_addafterdispose():	CODE
LOW	tests/test_disposables/test_disposable.py	137	def test_groupdisposable_remove():	CODE
LOW	tests/test_disposables/test_disposable.py	176	def test_groupdisposable_clear():	CODE
LOW	tests/test_disposables/test_disposable.py	209	def test_mutabledisposable_ctor_prop():	CODE
LOW	tests/test_disposables/test_disposable.py	214	def test_mutabledisposable_replacebeforedispose():	CODE
LOW	tests/test_disposables/test_disposable.py	239	def test_mutabledisposable_replaceafterdispose():	CODE
LOW	tests/test_disposables/test_disposable.py	264	def test_mutabledisposable_dispose():	CODE
LOW	tests/test_disposables/test_disposable.py	281	def test_refcountdisposable_singlereference():	CODE
LOW	tests/test_disposables/test_disposable.py	292	def test_refcountdisposable_refcounting():	CODE
LOW	tests/test_disposables/test_disposable.py	309	def test_refcountdisposable_primarydisposesfirst():	CODE
LOW	tests/test_subject/test_replaysubject.py	685	def test_replay_subject_dies_out():	CODE
LOW	tests/test_core/test_observer.py	30	def test_to_observer_notification_on_next() -> None:	CODE
LOW	tests/test_core/test_observer.py	44	def test_to_observer_notification_on_error() -> None:	CODE
LOW	tests/test_core/test_observer.py	58	def test_to_observer_notification_completed() -> None:	CODE
LOW	tests/test_core/test_observer.py	70	def test_to_notifier_forwards() -> None:	CODE
LOW	tests/test_core/test_observer.py	99	def test_create_on_next_has_error() -> None:	CODE
LOW	tests/test_core/test_observer.py	122	def test_create_on_next_on_completed() -> None:	CODE
LOW	tests/test_core/test_observer.py	145	def test_create_on_next_close_has_error() -> None:	CODE
LOW	tests/test_core/test_observer.py	173	def test_create_on_next_on_error() -> None:	CODE
LOW	tests/test_core/test_observer.py	197	def test_create_on_next_throw_hit_completed() -> None:	CODE
LOW	tests/test_core/test_observer.py	291	def test_as_observer_forwards() -> None:	CODE
LOW	tests/test_core/test_priorityqueue.py	50	def test_priorityqueue_length(self) -> None:	CODE
LOW	tests/test_core/test_priorityqueue.py	67	def test_priorityqueue_enqueue_dequeue(self) -> None:	CODE
LOW	tests/test_core/test_priorityqueue.py	79	def test_priorityqueue_sort_stability(self) -> None:	CODE
LOW	tests/test_core/test_priorityqueue.py	99	def test_priorityqueue_remove(self) -> None:	CODE
LOW	tests/test_core/test_notification.py	16	def test_on_next_ctor_and_props() -> None:	CODE
LOW	tests/test_core/test_notification.py	61	def test_on_next_accept_observer() -> None:	CODE
LOW	tests/test_core/test_notification.py	89	def test_on_next_accept_observer_with_result() -> None:	CODE
LOW	tests/test_core/test_notification.py	106	def test_on_next_accept_action() -> None:	CODE
LOW	tests/test_core/test_notification.py	124	def test_on_next_accept_action_with_result() -> None:	CODE
LOW	tests/test_core/test_notification.py	141	def test_throw_ctor_and_props() -> None:	CODE
LOW	tests/test_core/test_notification.py	189	def test_throw_accept_observer() -> None:	CODE
LOW	tests/test_core/test_notification.py	197	def test_throw_accept_observer_with_result() -> None:	CODE
LOW	tests/test_core/test_notification.py	233	def test_throw_accept_action_with_result() -> None:	CODE
LOW	tests/test_core/test_notification.py	251	def test_close_ctor_and_props() -> None:	CODE
LOW	tests/test_core/test_notification.py	291	def test_close_accept_observer() -> None:	CODE
LOW	tests/test_core/test_notification.py	298	def test_close_accept_observer_with_result() -> None:	CODE
LOW	tests/test_core/test_notification.py	332	def test_close_accept_action_with_result() -> None:	CODE
LOW	tests/test_core/test_notification.py	362	def test_to_observable_return() -> None:	CODE
LOW	tests/test_core/test_notification.py	378	def test_to_observable_on_error() -> None:	CODE
LOW	tests/test_testing/test_marbles.py	14	# def test_new_thread_scheduler(self):	COMMENT
LOW⚡	tests/test_testing/test_marbles.py	25	# def test_timeout_new_thread_scheduler(self):	COMMENT
LOW⚡	tests/test_testing/test_marbles.py	28	# def test_new_thread_scheduler_timeout(self):	COMMENT
LOW⚡	tests/test_testing/test_marbles.py	31	# def test_timeout_testscheduler(self):	COMMENT
LOW⚡	tests/test_testing/test_marbles.py	38	# def test_newthread_testscheduler(self):	COMMENT
LOW⚡	tests/test_testing/test_marbles.py	47	def test_start_with_cold_never(self) -> None:	CODE
LOW	tests/test_testing/test_marbles.py	59	def test_start_with_cold_empty(self) -> None:	CODE
LOW	tests/test_testing/test_marbles.py	71	def test_start_with_cold_normal(self) -> None:	CODE
LOW	tests/test_testing/test_marbles.py	87	def test_start_with_cold_no_create_function(self) -> None:	CODE
LOW	tests/test_testing/test_marbles.py	100	def test_start_with_hot_never(self) -> None:	CODE
LOW	tests/test_testing/test_marbles.py	112	def test_start_with_hot_empty(self) -> None:	CODE
LOW	tests/test_testing/test_marbles.py	126	def test_start_with_hot_normal(self) -> None:	CODE
LOW	tests/test_testing/test_marbles.py	156	def test_start_with_hot_and_exp(self) -> None:	CODE
LOW	tests/test_testing/test_marbles.py	168	def test_start_with_cold_and_exp(self) -> None:	CODE
LOW	tests/test_testing/test_marbles.py	180	def test_start_with_cold_and_exp_group(self) -> None:	CODE
LOW	tests/test_scheduler/test_immediatescheduler.py	64	def test_immediate_scheduleaction(self):	CODE
907 more matches not shown…

Cross-File Repetition70 hits · 350 pts

Severity	File	Line	Snippet	Context
HIGH	tests/test_observable/test_testing_fluent.py	0	verify pairwise fluent and functional styles are equivalent.	STRING
HIGH	tests/test_observable/test_transformation_fluent.py	0	verify pairwise fluent and functional styles are equivalent.	STRING
HIGH	tests/test_observable/test_filtering_fluent.py	0	verify pairwise fluent and functional styles are equivalent.	STRING
HIGH	tests/test_observable/test_multicasting_fluent.py	0	verify pairwise fluent and functional styles are equivalent.	STRING
HIGH	tests/test_observable/test_conditional_fluent.py	0	verify pairwise fluent and functional styles are equivalent.	STRING
HIGH	tests/test_observable/test_error_handling_fluent.py	0	verify pairwise fluent and functional styles are equivalent.	STRING
HIGH	tests/test_observable/test_combination_fluent.py	0	verify pairwise fluent and functional styles are equivalent.	STRING
HIGH	tests/test_observable/test_mathematical_fluent.py	0	verify pairwise fluent and functional styles are equivalent.	STRING
HIGH	tests/test_observable/test_time_based_fluent.py	0	verify pairwise fluent and functional styles are equivalent.	STRING
HIGH	tests/test_observable/test_utility_fluent.py	0	verify pairwise fluent and functional styles are equivalent.	STRING
HIGH	tests/test_observable/test_windowing_fluent.py	0	verify pairwise fluent and functional styles are equivalent.	STRING
HIGH	reactivex/abc/periodicscheduler.py	0	schedules a periodic piece of work. args: period: period in seconds or timedelta for running the work periodically. acti	STRING
HIGH	reactivex/scheduler/periodicscheduler.py	0	schedules a periodic piece of work. args: period: period in seconds or timedelta for running the work periodically. acti	STRING
HIGH	reactivex/scheduler/catchscheduler.py	0	schedules a periodic piece of work. args: period: period in seconds or timedelta for running the work periodically. acti	STRING
HIGH	reactivex/scheduler/newthreadscheduler.py	0	schedules a periodic piece of work. args: period: period in seconds or timedelta for running the work periodically. acti	STRING
HIGH	reactivex/scheduler/eventloopscheduler.py	0	schedules a periodic piece of work. args: period: period in seconds or timedelta for running the work periodically. acti	STRING
HIGH	reactivex/abc/scheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/catchscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/newthreadscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/virtualtimescheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/scheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/trampolinescheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/eventloopscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/immediatescheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/timeoutscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/mainloop/tkinterscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/mainloop/pygamescheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/mainloop/qtscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/mainloop/wxscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/mainloop/gtkscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/eventloop/eventletscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/eventloop/twistedscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	…ivex/scheduler/eventloop/asynciothreadsafescheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/eventloop/ioloopscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/eventloop/geventscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/scheduler/eventloop/asyncioscheduler.py	0	schedules an action to be executed. args: action: action to be executed. state: [optional] state to be given to the acti	STRING
HIGH	reactivex/abc/scheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/catchscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/newthreadscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/virtualtimescheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/scheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/trampolinescheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/eventloopscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/immediatescheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/timeoutscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/mainloop/tkinterscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/mainloop/pygamescheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/mainloop/qtscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/mainloop/wxscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/mainloop/gtkscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/eventloop/eventletscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/eventloop/twistedscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	…ivex/scheduler/eventloop/asynciothreadsafescheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/eventloop/ioloopscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/eventloop/geventscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/eventloop/asyncioscheduler.py	0	schedules an action to be executed at duetime. args: duetime: absolute time at which to execute the action. action: acti	STRING
HIGH	reactivex/scheduler/mainloop/qtscheduler.py	0	schedules a periodic piece of work to be executed in the loop. args: period: period in seconds for running the work repe	STRING
HIGH	reactivex/scheduler/mainloop/wxscheduler.py	0	schedules a periodic piece of work to be executed in the loop. args: period: period in seconds for running the work repe	STRING
HIGH	reactivex/scheduler/mainloop/gtkscheduler.py	0	schedules a periodic piece of work to be executed in the loop. args: period: period in seconds for running the work repe	STRING
HIGH	reactivex/observable/mixins/transformation.py	0	cast mixin instance to observable preserving type parameter. this is safe because this mixin is only ever used as part o	STRING
10 more matches not shown…

Modern Structural Boilerplate161 hits · 161 pts

Severity	File	Line	Snippet	Context
LOW	reactivex/__init__.py	1299	__all__ = [	CODE
LOW	reactivex/typing.py	59	__all__ = [	CODE
LOW	reactivex/pipe.py	204	__all__ = ["pipe", "compose"]	CODE
LOW	reactivex/abc/observer.py	49	__all__ = ["ObserverBase", "OnNext", "OnError", "OnCompleted"]	CODE
LOW	reactivex/abc/startable.py	14	__all__ = ["StartableBase"]	CODE
LOW	reactivex/abc/subject.py	72	__all__ = ["SubjectBase"]	CODE
LOW	reactivex/abc/periodicscheduler.py	45	__all__ = [	CODE
LOW	reactivex/abc/observable.py	52	__all__ = ["ObservableBase", "Subscription"]	CODE
LOW	reactivex/abc/__init__.py	9	__all__ = [	CODE
LOW	reactivex/abc/disposable.py	33	__all__ = ["DisposableBase"]	CODE
LOW	reactivex/abc/scheduler.py	152	__all__ = [	CODE
LOW	reactivex/operators/_sum.py	37	__all__ = ["sum_"]	CODE
LOW	reactivex/operators/_skiplastwithtime.py	70	__all__ = ["skip_last_with_time_"]	CODE
LOW	reactivex/operators/_onerrorresumenext.py	29	__all__ = ["on_error_resume_next_"]	CODE
LOW	reactivex/operators/_takelastwithtime.py	72	__all__ = ["take_last_with_time_"]	CODE
LOW	reactivex/operators/_subscribeon.py	60	__all__ = ["subscribe_on_"]	CODE
LOW	reactivex/operators/_expand.py	107	__all__ = ["expand_"]	CODE
LOW	reactivex/operators/_minby.py	92	__all__ = ["min_by_"]	CODE
LOW	reactivex/operators/_pluck.py	47	__all__ = ["pluck_", "pluck_attr_"]	CODE
LOW	reactivex/operators/_asobservable.py	34	__all__ = ["as_observable_"]	CODE
LOW	reactivex/operators/_isempty.py	35	__all__ = ["is_empty_"]	CODE
LOW	reactivex/operators/_windowwithcount.py	94	__all__ = ["window_with_count_"]	CODE
LOW	reactivex/operators/_maxby.py	40	__all__ = ["max_by_"]	CODE
LOW	reactivex/operators/_todict.py	72	__all__ = ["to_dict_"]	CODE
LOW	reactivex/operators/_skipuntilwithtime.py	70	__all__ = ["skip_until_with_time_"]	CODE
LOW	reactivex/operators/_takewithtime.py	58	__all__ = ["take_with_time_"]	CODE
LOW⚡	reactivex/operators/_distinct.py	88	__all__ = ["distinct_"]	CODE
LOW	reactivex/operators/_withlatestfrom.py	36	__all__ = ["with_latest_from_"]	CODE
LOW	reactivex/operators/_takeuntil.py	52	__all__ = ["take_until_"]	CODE
LOW	reactivex/operators/_ignoreelements.py	37	__all__ = ["ignore_elements_"]	CODE
LOW	reactivex/operators/_delaysubscription.py	40	__all__ = ["delay_subscription_"]	CODE
LOW	reactivex/operators/_switchlatest.py	92	__all__ = ["switch_latest_"]	CODE
LOW	reactivex/operators/_takewhile.py	129	__all__ = ["take_while_", "take_while_indexed_"]	CODE
LOW	reactivex/operators/_windowwithtime.py	137	__all__ = ["window_with_time_"]	CODE
LOW	reactivex/operators/_dematerialize.py	40	__all__ = ["dematerialize_"]	CODE
LOW	reactivex/operators/_tofuture.py	76	__all__ = ["to_future_"]	CODE
LOW	reactivex/operators/_exclusive.py	80	__all__ = ["exclusive_"]	CODE
LOW	reactivex/operators/_forkjoin.py	33	__all__ = ["fork_join_"]	CODE
LOW	reactivex/operators/_defaultifempty.py	55	__all__ = ["default_if_empty_"]	CODE
LOW	reactivex/operators/_startswith.py	30	__all__ = ["start_with_"]	CODE
LOW	reactivex/operators/_delaywithmapper.py	108	__all__ = ["delay_with_mapper_"]	CODE
LOW	reactivex/operators/_zip.py	87	__all__ = ["zip_", "zip_with_iterable_"]	CODE
LOW	reactivex/operators/_filter.py	93	__all__ = ["filter_", "filter_indexed_"]	CODE
LOW	reactivex/operators/_last.py	49	__all__ = ["last_"]	CODE
LOW	reactivex/operators/_take.py	57	__all__ = ["take_"]	CODE
LOW	reactivex/operators/_throttlefirst.py	64	__all__ = ["throttle_first_"]	CODE
LOW	reactivex/operators/_map.py	86	__all__ = ["map_", "map_indexed_"]	CODE
LOW	reactivex/operators/_min.py	50	__all__ = ["min_"]	CODE
LOW	reactivex/operators/_sample.py	84	__all__ = ["sample_"]	CODE
LOW	reactivex/operators/_elementatordefault.py	75	__all__ = ["element_at_or_default_"]	CODE
LOW	reactivex/operators/_takelastbuffer.py	56	__all__ = ["take_last_buffer_"]	CODE
LOW	reactivex/operators/_tomarbles.py	89	__all__ = ["to_marbles", "stringify"]	CODE
LOW	reactivex/operators/_buffer.py	126	__all__ = ["buffer_", "buffer_with_count_", "buffer_when_", "buffer_toggle_"]	CODE
LOW	reactivex/operators/_sequenceequal.py	125	__all__ = ["sequence_equal_"]	CODE
LOW	reactivex/operators/_windowwithtimeorcount.py	116	__all__ = ["window_with_time_or_count_"]	CODE
LOW	reactivex/operators/_find.py	63	__all__ = ["find_value_"]	CODE
LOW	reactivex/operators/_slice.py	80	__all__ = ["slice_"]	CODE
LOW	reactivex/operators/_scan.py	62	__all__ = ["scan_"]	CODE
LOW	reactivex/operators/_skipwithtime.py	70	__all__ = ["skip_with_time_"]	CODE
LOW	reactivex/operators/_bufferwithtimeorcount.py	40	__all__ = ["buffer_with_time_or_count_"]	CODE
101 more matches not shown…

Cross-Language Confusion22 hits · 160 pts

Severity	File	Line	Snippet	Context
HIGH⚡	tests/test_core/test_notification.py	29	assert n1.equals(n1)	CODE
HIGH⚡	tests/test_core/test_notification.py	30	assert n1.equals(n2)	CODE
HIGH⚡	tests/test_core/test_notification.py	31	assert n2.equals(n1)	CODE
HIGH⚡	tests/test_core/test_notification.py	33	assert not n1.equals(n3)	CODE
HIGH⚡	tests/test_core/test_notification.py	34	assert not n3.equals(n1)	CODE
HIGH⚡	tests/test_core/test_notification.py	35	assert not n1.equals(n4)	CODE
HIGH⚡	tests/test_core/test_notification.py	36	assert not n4.equals(n1)	CODE
HIGH⚡	tests/test_core/test_notification.py	156	assert n1.equals(n1)	CODE
HIGH⚡	tests/test_core/test_notification.py	157	assert n1.equals(n2)	CODE
HIGH⚡	tests/test_core/test_notification.py	158	assert n2.equals(n1)	CODE
HIGH⚡	tests/test_core/test_notification.py	160	assert not n1.equals(n3)	CODE
HIGH⚡	tests/test_core/test_notification.py	161	assert not n3.equals(n1)	CODE
HIGH⚡	tests/test_core/test_notification.py	162	assert not n1.equals(n4)	CODE
HIGH⚡	tests/test_core/test_notification.py	163	assert not n4.equals(n1)	CODE
HIGH⚡	tests/test_core/test_notification.py	262	assert n1.equals(n1)	CODE
HIGH⚡	tests/test_core/test_notification.py	263	assert n1.equals(n2)	CODE
HIGH⚡	tests/test_core/test_notification.py	264	assert n2.equals(n1)	CODE
HIGH⚡	tests/test_core/test_notification.py	266	assert not n1.equals(n3)	CODE
HIGH⚡	tests/test_core/test_notification.py	267	assert not n3.equals(n1)	CODE
HIGH	reactivex/notification.py	103	return self.equals(other)	CODE
HIGH⚡	reactivex/operators/_distinct.py	78	if hashset.push(key):	CODE
HIGH	reactivex/testing/subscription.py	16	return self.equals(other)	CODE

Unused Imports138 hits · 132 pts

Severity	File	Line	Context
LOW	reactivex/__init__.py	12	CODE
LOW	reactivex/__init__.py	14	CODE
LOW	reactivex/__init__.py	15	CODE
LOW	reactivex/__init__.py	15	CODE
LOW	reactivex/__init__.py	16	CODE
LOW	reactivex/__init__.py	17	CODE
LOW	reactivex/__init__.py	17	CODE
LOW	reactivex/__init__.py	18	CODE
LOW	reactivex/typing.py	9	CODE
LOW	reactivex/typing.py	10	CODE
LOW	reactivex/typing.py	10	CODE
LOW	reactivex/typing.py	10	CODE
LOW	reactivex/typing.py	11	CODE
LOW	reactivex/typing.py	11	CODE
LOW	reactivex/typing.py	15	CODE
LOW	reactivex/typing.py	15	CODE
LOW	reactivex/typing.py	15	CODE
LOW	reactivex/typing.py	15	CODE
LOW	reactivex/abc/__init__.py	1	CODE
LOW	reactivex/abc/__init__.py	2	CODE
LOW	reactivex/abc/__init__.py	2	CODE
LOW	reactivex/abc/__init__.py	3	CODE
LOW	reactivex/abc/__init__.py	3	CODE
LOW	reactivex/abc/__init__.py	3	CODE
LOW	reactivex/abc/__init__.py	3	CODE
LOW	reactivex/abc/__init__.py	4	CODE
LOW	reactivex/abc/__init__.py	5	CODE
LOW	reactivex/abc/__init__.py	5	CODE
LOW	reactivex/abc/__init__.py	6	CODE
LOW	reactivex/abc/__init__.py	7	CODE
LOW	reactivex/abc/disposable.py	1	CODE
LOW	reactivex/operators/_takeuntil.py	6	CODE
LOW	reactivex/operators/_switchlatest.py	10	CODE
LOW	reactivex/operators/_exclusive.py	7	CODE
LOW	reactivex/operators/__init__.py	4	CODE
LOW	reactivex/operators/__init__.py	3773	CODE
LOW	reactivex/operators/__init__.py	3878	CODE
LOW	reactivex/operators/_whiledo.py	8	CODE
LOW	reactivex/operators/_skipuntil.py	6	CODE
LOW	reactivex/operators/_catch.py	8	CODE
LOW	reactivex/operators/_flatmap.py	7	CODE
LOW	reactivex/operators/_amb.py	6	CODE
LOW	reactivex/subject/__init__.py	1	CODE
LOW	reactivex/subject/__init__.py	2	CODE
LOW	reactivex/subject/__init__.py	3	CODE
LOW	reactivex/subject/__init__.py	4	CODE
LOW	reactivex/subject/innersubscription.py	7	CODE
LOW	reactivex/internal/__init__.py	1	CODE
LOW	reactivex/internal/__init__.py	1	CODE
LOW	reactivex/internal/__init__.py	1	CODE
LOW	reactivex/internal/__init__.py	2	CODE
LOW	reactivex/internal/__init__.py	2	CODE
LOW	reactivex/internal/__init__.py	3	CODE
LOW	reactivex/internal/__init__.py	3	CODE
LOW	reactivex/internal/__init__.py	4	CODE
LOW	reactivex/internal/__init__.py	5	CODE
LOW	reactivex/internal/__init__.py	5	CODE
LOW	reactivex/internal/__init__.py	5	CODE
LOW	reactivex/internal/__init__.py	10	CODE
LOW	reactivex/internal/__init__.py	11	CODE
78 more matches not shown…

Excessive Try-Catch Wrapping71 hits · 76 pts

Severity	File	Line	Snippet	Context
LOW	tests/test_core/test_observer.py	116	except Exception as e:	CODE
LOW	tests/test_core/test_observer.py	166	except Exception as e:	CODE
LOW⚡	…/test_scheduler/test_mainloop/test_tkinterscheduler.py	26	except Exception:	CODE
LOW	tests/test_observable/test_tofuture.py	56	except Exception as ex:	CODE
LOW	examples/autocomplete/bottle_autocomplete.py	31	except Exception as ex:	CODE
MEDIUM	examples/autocomplete/bottle_autocomplete.py	27	def subscribe(self, on_next, on_err, on_compl):	CODE
LOW	reactivex/operators/_expand.py	75	except Exception as ex:	CODE
LOW	reactivex/operators/_minby.py	28	except Exception as ex:	CODE
LOW	reactivex/operators/_minby.py	40	except Exception as ex1:	CODE
LOW	reactivex/operators/_todict.py	44	except Exception as ex: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_todict.py	51	except Exception as ex: # pylint: disable=broad-except	CODE
LOW⚡	reactivex/operators/_distinct.py	74	except Exception as ex:	CODE
LOW	reactivex/operators/_takewhile.py	50	except Exception as exn:	CODE
LOW	reactivex/operators/_takewhile.py	109	except Exception as exn:	CODE
LOW	reactivex/operators/_delaywithmapper.py	64	except Exception as error: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_filter.py	33	except Exception as ex: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_filter.py	77	except Exception as ex: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_map.py	42	except Exception as err: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_sequenceequal.py	59	except Exception as e:	CODE
LOW	reactivex/operators/_sequenceequal.py	88	except Exception as exception:	CODE
LOW	reactivex/operators/_find.py	42	except Exception as ex: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_distinctuntilchanged.py	60	except Exception as exception: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_distinctuntilchanged.py	67	except Exception as exception: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_finallyaction.py	34	except Exception:	CODE
LOW	reactivex/operators/_skipwhile.py	45	except Exception as exn:	CODE
LOW	reactivex/operators/_join.py	66	except Exception as exception:	CODE
LOW	reactivex/operators/_join.py	112	except Exception as exception:	CODE
LOW	reactivex/operators/_timeoutwithmapper.py	111	except Exception as e:	CODE
LOW	reactivex/operators/_catch.py	30	except Exception as ex: # By design. pylint: disable=W0703	CODE
LOW	reactivex/operators/_do.py	54	except Exception as e: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_do.py	65	except Exception as e: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_do.py	76	except Exception as e: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_do.py	123	except Exception as e: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_do.py	201	except Exception as err: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_do.py	209	except Exception as err: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_do.py	237	except Exception as err: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_do.py	244	except Exception as err: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_do.py	302	except Exception as err: # pylint: disable=broad-except	CODE
LOW	reactivex/operators/_do.py	311	except Exception as err: # pylint: disable=broad-except	CODE
MEDIUM	reactivex/operators/_do.py	198	def on_completed():	CODE
LOW	reactivex/operators/_groupbyuntil.py	86	except Exception as e:	CODE
LOW	reactivex/operators/_groupbyuntil.py	98	except Exception as e:	CODE
LOW	reactivex/operators/_groupbyuntil.py	117	except Exception as e:	CODE
LOW	reactivex/operators/_groupbyuntil.py	152	except Exception as error:	CODE
LOW	reactivex/operators/_window.py	155	except Exception as exception:	CODE
MEDIUM	reactivex/operators/_window.py	152	def create_window_on_completed():	CODE
LOW	reactivex/operators/_groupjoin.py	71	except Exception as e:	CODE
LOW	reactivex/operators/_groupjoin.py	96	except Exception as e:	CODE
LOW	reactivex/operators/_groupjoin.py	143	except Exception as e:	CODE
LOW	reactivex/operators/_debounce.py	121	except Exception as e: # pylint: disable=broad-except	CODE
LOW	reactivex/scheduler/periodicscheduler.py	50	except Exception:	CODE
LOW	reactivex/scheduler/catchscheduler.py	139	except Exception as ex:	CODE
LOW	reactivex/scheduler/catchscheduler.py	163	except Exception as ex:	CODE
LOW	…ivex/scheduler/eventloop/asynciothreadsafescheduler.py	101	except Exception:	CODE
MEDIUM	…ivex/scheduler/eventloop/asynciothreadsafescheduler.py	97	def do_cancel_handles() -> None:	CODE
LOW	reactivex/observer/scheduledobserver.py	71	except Exception:	CODE
LOW	reactivex/observable/toasync.py	42	except Exception as ex: # pylint: disable=broad-except	CODE
LOW	reactivex/observable/returnvalue.py	57	except Exception as e: # pylint: disable=broad-except	CODE
LOW	reactivex/observable/concat.py	40	except Exception as ex: # pylint: disable=broad-except	CODE
LOW	reactivex/observable/generate.py	41	except Exception as exception: # pylint: disable=broad-except	CODE
11 more matches not shown…

Over-Commented Block45 hits · 44 pts

Severity	File	Line	Snippet	Context
LOW	tests/test_testing/test_marbles.py	21		COMMENT
LOW	tests/test_observable/test_replay.py	321	connection2.dispose()	COMMENT
LOW	tests/test_observable/test_replay.py	341	# xs = scheduler.create_hot_observable(on_next(110, 7), on_next(220, 3), on_next(280, 4), on_next(290, 1), on_ne	COMMENT
LOW	tests/test_observable/test_replay.py	681	# on_next(360, 5),	COMMENT
LOW	tests/test_observable/test_replay.py	701	# on_next(280, 4),	COMMENT
LOW	tests/test_observable/test_replay.py	721	# on_next(600, 20),	COMMENT
LOW	tests/test_observable/test_replay.py	741	# on_next(450, 9),	COMMENT
LOW	tests/test_observable/test_replay.py	761	# on_next(371, 6),	COMMENT
LOW	tests/test_observable/test_replay.py	781	# scheduler = TestScheduler()	COMMENT
LOW	tests/test_observable/test_replay.py	801	# return _xs.take(6).repeat()	COMMENT
LOW	tests/test_observable/test_replay.py	821	# on_next(434, 2),	COMMENT
LOW	tests/test_observable/test_repeat.py	261	# with self.assertRaises(RxException):	COMMENT
LOW	tests/test_observable/test_doaction.py	221	# saw_error = False	COMMENT
LOW	tests/test_observable/test_doaction.py	241	# def create():	COMMENT
LOW	tests/test_observable/test_doaction.py	261	# return xs.do_action(function (x) {	COMMENT
LOW	tests/test_observable/test_doaction.py	281	# saw_error = False	COMMENT
LOW	tests/test_observable/test_doaction.py	301	# saw_error = False	COMMENT
LOW	tests/test_observable/test_doaction.py	321	# saw_error = False	COMMENT
LOW	tests/test_observable/test_doaction.py	341	# i = [0]	COMMENT
LOW	tests/test_observable/test_doaction.py	361	# ex = 'ex'	COMMENT
LOW	tests/test_observable/test_doaction.py	381		COMMENT
LOW	tests/test_observable/test_doaction.py	401		COMMENT
LOW	tests/test_observable/test_doaction.py	421	# xs = scheduler.create_hot_observable(on_next(150, 1), on_next(210, 2), on_completed(250)) # noqa: E501	COMMENT
LOW	tests/test_observable/test_doaction.py	441		COMMENT
LOW	tests/test_observable/test_doaction.py	461		COMMENT
LOW	tests/test_observable/test_doaction.py	481	# xs = scheduler.create_hot_observable(on_next(150, 1), on_next(210, 2), on_completed(250)) # noqa: E501	COMMENT
LOW	tests/test_observable/test_interval.py	41		COMMENT
LOW	tests/test_observable/test_takelastbuffer.py	181	def predicate(lst):	COMMENT
LOW	tests/test_observable/test_takelastbuffer.py	201	# scheduler = TestScheduler()	COMMENT
LOW	tests/test_observable/test_maxby.py	141	# ]	COMMENT
LOW	tests/test_observable/test_maxby.py	161	# def test_MaxBy_Comparer_Return():	COMMENT
LOW	tests/test_observable/test_maxby.py	181	# }	COMMENT
LOW	tests/test_observable/test_maxby.py	201	# value: 'z'	COMMENT
LOW	tests/test_observable/test_maxby.py	221	# }	COMMENT
LOW	tests/test_observable/test_maxby.py	241	# key: 1,	COMMENT
LOW	tests/test_observable/test_maxby.py	261		COMMENT
LOW	tests/test_observable/test_maxby.py	281	# res = scheduler.start(create=create)	COMMENT
LOW	tests/test_observable/test_maxby.py	301	# value: 'c'	COMMENT
LOW	docs/conf.py	81	# The master toctree document.	COMMENT
LOW	docs/conf.py	101		COMMENT
LOW	docs/conf.py	141	# -- Options for LaTeX output ------------------------------------------------	COMMENT
LOW	.github/lock.yml	21		COMMENT
LOW	.github/workflows/repo-assist.lock.yml	1	# gh-aw-metadata: {"schema_version":"v3","frontmatter_hash":"6e26bdb60d0e264d5569713ec5348ea3282628e6306a62ab226aa9ab394	COMMENT
LOW	.github/workflows/repo-assist.lock.yml	21	# Not all edits will cause changes to this file.	COMMENT
LOW	.github/workflows/repo-assist.lock.yml	41	# - GH_AW_GITHUB_MCP_SERVER_TOKEN	COMMENT

Modern AI Meta-Vocabulary8 hits · 21 pts

Severity	File	Line	Snippet	Context
MEDIUM	.github/agents/agentic-workflows.agent.md	34	- Configuration: https://github.com/github/gh-aw/blob/v0.71.5/.github/aw/github-agentic-workflows.md	CODE
MEDIUM⚡	.github/agents/agentic-workflows.agent.md	56	Prompt file: https://github.com/github/gh-aw/blob/v0.71.5/.github/aw/create-agentic-workflow.md	CODE
MEDIUM⚡	.github/agents/agentic-workflows.agent.md	66	Prompt file: https://github.com/github/gh-aw/blob/v0.71.5/.github/aw/update-agentic-workflow.md	CODE
MEDIUM⚡	.github/agents/agentic-workflows.agent.md	76	Prompt file: https://github.com/github/gh-aw/blob/v0.71.5/.github/aw/debug-agentic-workflow.md	CODE
MEDIUM⚡	.github/agents/agentic-workflows.agent.md	86	Prompt file: https://github.com/github/gh-aw/blob/v0.71.5/.github/aw/upgrade-agentic-workflows.md	CODE
MEDIUM	.github/agents/agentic-workflows.agent.md	106	Prompt file: https://github.com/github/gh-aw/blob/v0.71.5/.github/aw/create-shared-agentic-workflow.md	CODE
MEDIUM	.github/agents/agentic-workflows.agent.md	156	# Initialize repository for agentic workflows	COMMENT
MEDIUM	.github/agents/agentic-workflows.agent.md	188	- Always reference the instructions file at https://github.com/github/gh-aw/blob/v0.71.5/.github/aw/github-agentic-workf	CODE

Empty Error Handlers2 hits · 10 pts

Severity	File	Line	Snippet	Context
HIGH	…ivex/scheduler/eventloop/asynciothreadsafescheduler.py	101	except Exception:	CODE
HIGH	reactivex/observable/marbles.py	73	except ValueError:	CODE

Deep Nesting8 hits · 8 pts

Severity	File	Line	Context
LOW	examples/chess/chess.py	15	CODE
LOW	reactivex/operators/_delay.py	21	CODE
LOW	reactivex/operators/_delay.py	26	CODE
LOW	reactivex/operators/_delay.py	44	CODE
LOW	reactivex/scheduler/virtualtimescheduler.py	117	CODE
LOW	reactivex/scheduler/virtualtimescheduler.py	160	CODE
LOW	reactivex/scheduler/eventloopscheduler.py	152	CODE
LOW	reactivex/scheduler/trampoline.py	35	CODE

Redundant / Tautological Comments3 hits · 3 pts

Severity	File	Line	Snippet	Context
LOW	tests/test_observable/test_filtering_fluent.py	437	.all(lambda x: x > 3) # Check if all > 3	CODE
LOW	reactivex/operators/_switchlatest.py	55	# Check if Future or Observable	COMMENT
LOW	reactivex/observable/mixins/testing.py	75	>>> result = source.some() # Check if sequence is not empty	STRING

Self-Referential Comments1 hit · 3 pts

Severity	File	Line	Snippet	Context
MEDIUM	reactivex/operators/_retry.py	42	# Create a fresh generator on every subscription so that the retry	COMMENT

AI Slop Vocabulary2 hits · 2 pts

Severity	File	Line	Snippet	Context
MEDIUM	reactivex/operators/__init__.py	2084	"""Wraps the source sequence in order to run its observer callbacks	STRING
MEDIUM	reactivex/operators/_observeon.py	15	"""Wraps the source sequence in order to run its observer	STRING

AI Structural Patterns1 hit · 1 pts

Severity	File	Line	Snippet	Context
LOW	reactivex/operators/_average.py	62		CODE

Maintenance and Governance Review

Risk Review · v3

What These Metrics Mean

Pattern-Signal History

Severity Breakdown

Directory Score Breakdown

Pattern Findings