Skip to content

Commit

Permalink
undo event.py imports re-organization as it causes circular dependencies
Browse files Browse the repository at this point in the history
  • Loading branch information
gnzsnz committed Aug 20, 2024
1 parent e8c314d commit e6faadc
Showing 1 changed file with 84 additions and 82 deletions.
166 changes: 84 additions & 82 deletions eventkit/event.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,88 +5,6 @@
from typing import Any as AnyType
from typing import AsyncIterable, Awaitable, Iterable, List, Optional, Tuple, Union

from .ops.aggregate import (
All,
Any,
Count,
Deque,
Ema,
Max,
Mean,
Min,
Pairwise,
Product,
Reduce,
Sum,
)
from .ops.aggregate import List as ListOp
from .ops.array import (
Array,
ArrayAll,
ArrayAny,
ArrayMax,
ArrayMean,
ArrayMin,
ArrayProd,
ArrayStd,
ArraySum,
)
from .ops.combine import (
AddableJoinOp,
Chain,
Concat,
Fork,
Merge,
Switch,
Zip,
Ziplatest,
)
from .ops.create import (
Aiterate,
Marble,
Range,
Repeat,
Sequence,
Timer,
Timerange,
Wait,
)
from .ops.misc import EndOnError, Errors
from .ops.op import Op
from .ops.select import (
Changes,
DropWhile,
Filter,
Last,
Skip,
Take,
TakeUntil,
TakeWhile,
Unique,
)
from .ops.timing import Debounce, Delay, Sample, Throttle, Timeout
from .ops.transform import (
Chainmap,
Chunk,
ChunkWith,
Concatmap,
Constant,
Copy,
Deepcopy,
Emap,
Enumerate,
Iterate,
Map,
Mergemap,
Pack,
Partial,
PartialRight,
Pluck,
Previous,
Star,
Switchmap,
Timestamp,
)
from .util import NO_VALUE, get_event_loop


Expand Down Expand Up @@ -1444,3 +1362,87 @@ def end_on_error(self) -> "EndOnError":
End on any error from the source.
"""
return EndOnError(self)


from .ops.aggregate import (
All,
Any,
Count,
Deque,
Ema,
Max,
Mean,
Min,
Pairwise,
Product,
Reduce,
Sum,
)
from .ops.aggregate import List as ListOp
from .ops.array import (
Array,
ArrayAll,
ArrayAny,
ArrayMax,
ArrayMean,
ArrayMin,
ArrayProd,
ArrayStd,
ArraySum,
)
from .ops.combine import (
AddableJoinOp,
Chain,
Concat,
Fork,
Merge,
Switch,
Zip,
Ziplatest,
)
from .ops.create import (
Aiterate,
Marble,
Range,
Repeat,
Sequence,
Timer,
Timerange,
Wait,
)
from .ops.misc import EndOnError, Errors
from .ops.op import Op
from .ops.select import (
Changes,
DropWhile,
Filter,
Last,
Skip,
Take,
TakeUntil,
TakeWhile,
Unique,
)
from .ops.timing import Debounce, Delay, Sample, Throttle, Timeout
from .ops.transform import (
Chainmap,
Chunk,
ChunkWith,
Concatmap,
Constant,
Copy,
Deepcopy,
Emap,
Enumerate,
Iterate,
Map,
Mergemap,
Pack,
Partial,
PartialRight,
Pluck,
Previous,
Star,
Switchmap,
Timestamp,
)

0 comments on commit e6faadc

Please sign in to comment.