Skip to content

Commit fa6e837

Browse files
committed
Updated doc comment.
1 parent d77b260 commit fa6e837

File tree

1 file changed

+5
-1
lines changed
  • runtime/swim_runtime/src/timeout_coord

1 file changed

+5
-1
lines changed

runtime/swim_runtime/src/timeout_coord/mod.rs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,10 @@ pub fn agent_timeout_coordinator() -> (Voter, Voter, Voter, Receiver) {
7474
(sender1, sender2, sender3, receiver)
7575
}
7676

77+
/// Allows the read and write parts of the downlink runtime to vote on when the runtime should stop.
78+
/// The [`Receiver`] future will only complete when both [`Sender`]s have voted to stop. If only one
79+
/// sender has voted to stop, it may rescind its vote. Rescinding a vote will only be respected if unanimity
80+
/// was not reached.
7781
pub fn downlink_timeout_coordinator() -> (Voter, Voter, Receiver) {
7882
let ([sender1, sender2], receiver) = multi_party_coordinator::<2>();
7983
(sender1, sender2, receiver)
@@ -119,7 +123,7 @@ impl NumParties for [Voter; 8] {
119123
}
120124
}
121125

122-
pub fn multi_party_coordinator<const N: usize>() -> ([Voter; N], Receiver)
126+
pub(crate) fn multi_party_coordinator<const N: usize>() -> ([Voter; N], Receiver)
123127
where
124128
[Voter; N]: NumParties,
125129
{

0 commit comments

Comments
 (0)