/// Create a channel for publishing and receiving updates to the pool's generation.
Create a channel for publishing and receiving updates to the pool's generation.
Create a channel for publishing and receiving updates to the pool ' s generation .
pub(super) fn channel(init: PoolGeneration) -> (PoolGenerationPublisher, PoolGenerationSubscriber) {
    let (sender, receiver) = tokio::sync::watch::channel(PoolStatus { generation: init });
    (
        PoolGenerationPublisher { sender },
        PoolGenerationSubscriber { receiver },
    )
}
pub ( super ) fn channel ( init : PoolGeneration ) -> ( PoolGenerationPublisher , PoolGenerationSubscriber ) { let ( sender , receiver ) = tokio :: sync :: watch :: channel ( PoolStatus { generation : init } ) ; ( PoolGenerationPublisher { sender } , PoolGenerationSubscriber { receiver } , ) }
Create a channel for publishing and receiving updates to the pool's generation.
Create a channel for publishing and receiving updates to the pool ' s generation .
init
PoolGeneration