diff --git a/broqer/operator_overloading.py b/broqer/operator_overloading.py index 22a84b2..28c5714 100644 --- a/broqer/operator_overloading.py +++ b/broqer/operator_overloading.py @@ -4,7 +4,6 @@ from typing import Any as Any_ # pylint: disable=cyclic-import -import broqer from broqer import Publisher from broqer.operator import Operator @@ -125,9 +124,9 @@ def apply_operator_overloading(): '__getitem__', '__floordiv__', '__truediv__'): def _op(operand_left, operand_right, operation=method): if isinstance(operand_right, Publisher): - return broqer.op.CombineLatest(operand_left, operand_right, - map_=getattr(operator, - operation)) + from broqer.op import CombineLatest + return CombineLatest(operand_left, operand_right, + map_=getattr(operator, operation)) return MapConstant(operand_left, operand_right, getattr(operator, operation))