Skip to content

Commit 5351d41

Browse files
committed
Rename Clonable*SenderCloneable*Sender
Signed-off-by: Sahas Subramanian <sahas.subramanian@proton.me>
1 parent 8559a81 commit 5351d41

3 files changed

Lines changed: 10 additions & 10 deletions

File tree

src/frequenz/channels/__init__.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -102,8 +102,8 @@
102102
selected_from,
103103
)
104104
from ._sender import (
105-
ClonableSender,
106-
ClonableSubscribableSender,
105+
CloneableSender,
106+
CloneableSubscribableSender,
107107
Sender,
108108
SenderClosedError,
109109
SenderError,
@@ -119,8 +119,8 @@
119119
"ChannelClosedError",
120120
"ChannelError",
121121
"ChannelMessageT",
122-
"ClonableSender",
123-
"ClonableSubscribableSender",
122+
"CloneableSender",
123+
"CloneableSubscribableSender",
124124
"Error",
125125
"ErroredChannelT_co",
126126
"LatestValueCache",

src/frequenz/channels/_broadcast.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
from ._exceptions import ChannelClosedError
1717
from ._generic import ChannelMessageT
1818
from ._receiver import Receiver, ReceiverStoppedError
19-
from ._sender import ClonableSubscribableSender, SenderClosedError, SenderError
19+
from ._sender import CloneableSubscribableSender, SenderClosedError, SenderError
2020

2121
_logger = logging.getLogger(__name__)
2222

@@ -334,7 +334,7 @@ def __repr__(self) -> str:
334334
_T = TypeVar("_T")
335335

336336

337-
class BroadcastSender(ClonableSubscribableSender[_T]):
337+
class BroadcastSender(CloneableSubscribableSender[_T]):
338338
"""A sender to send messages to the broadcast channel.
339339
340340
Should not be created directly, but through the

src/frequenz/channels/_sender.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -126,21 +126,21 @@ def subscribe(self) -> Receiver[SenderMessageT_contra]:
126126
"""
127127

128128

129-
class ClonableSender(Sender[SenderMessageT_contra], ABC):
129+
class CloneableSender(Sender[SenderMessageT_contra], ABC):
130130
"""A [Sender][frequenz.channels.Sender] that can be cloned."""
131131

132132
@abstractmethod
133-
def clone(self) -> ClonableSender[SenderMessageT_contra]:
133+
def clone(self) -> CloneableSender[SenderMessageT_contra]:
134134
"""Clone this sender.
135135
136136
Returns:
137137
A new sender that sends messages to the same channel as this sender.
138138
"""
139139

140140

141-
class ClonableSubscribableSender(
141+
class CloneableSubscribableSender(
142142
SubscribableSender[SenderMessageT_contra],
143-
ClonableSender[SenderMessageT_contra],
143+
CloneableSender[SenderMessageT_contra],
144144
ABC,
145145
):
146146
"""A [Sender][frequenz.channels.Sender] that can be both cloned and subscribed to."""

0 commit comments

Comments
 (0)