diff --git a/src/cpl_reactive_extensions/internal/operator_subscriber.py b/src/cpl_reactive_extensions/internal/operator_subscriber.py index f81be949..77ba0cd7 100644 --- a/src/cpl_reactive_extensions/internal/operator_subscriber.py +++ b/src/cpl_reactive_extensions/internal/operator_subscriber.py @@ -1,7 +1,7 @@ from typing import Callable from cpl_core.type import T -from cpl_reactive_extensions.abc import Observer +from cpl_reactive_extensions.abc.observer import Observer from cpl_reactive_extensions.internal.subscriber import Subscriber diff --git a/src/cpl_reactive_extensions/operators/debounce_time.py b/src/cpl_reactive_extensions/operators/debounce_time.py index 8ea1c421..4a0ccfd8 100644 --- a/src/cpl_reactive_extensions/operators/debounce_time.py +++ b/src/cpl_reactive_extensions/operators/debounce_time.py @@ -1,7 +1,7 @@ from typing import Optional from cpl_core.type import T, Number -from cpl_reactive_extensions.abc import SchedulerAction +from cpl_reactive_extensions.abc.scheduler_action import SchedulerAction from cpl_reactive_extensions.internal.operator_subscriber import OperatorSubscriber from cpl_reactive_extensions.internal.subscriber import Subscriber from cpl_reactive_extensions.internal.subscription import Subscription diff --git a/unittests/unittests_reactive_extenstions/observable_operator_test_case.py b/unittests/unittests_reactive_extenstions/observable_operator_test_case.py index 413a82a7..d3bb257c 100644 --- a/unittests/unittests_reactive_extenstions/observable_operator_test_case.py +++ b/unittests/unittests_reactive_extenstions/observable_operator_test_case.py @@ -4,7 +4,7 @@ import unittest from cpl_core.console import Console from cpl_reactive_extensions.observable import Observable -from cpl_reactive_extensions.operators import debounce_time +from cpl_reactive_extensions.operators.debounce_time import debounce_time from cpl_reactive_extensions.subject.subject import Subject from cpl_reactive_extensions.interval import Interval from cpl_reactive_extensions.operators.take import take