fn cancellations() -> (RequestCancellation, CanceledRequests) {
    // Unbounded because messages are sent in the drop fn. This is fine, because it's still
    // bounded by the number of in-flight requests.
    let (tx, rx) = mpsc::unbounded_channel();
    (RequestCancellation(tx), CanceledRequests(rx))
}
/// Returns a channel to send request cancellation messages.
Returns a channel to send request cancellation messages.
Returns a channel to send request cancellation messages .
fn cancellations() -> (RequestCancellation, CanceledRequests) {
    // Unbounded because messages are sent in the drop fn. This is fine, because it's still
    // bounded by the number of in-flight requests.
    let (tx, rx) = mpsc::unbounded_channel();
    (RequestCancellation(tx), CanceledRequests(rx))
}
fn cancellations ( ) -> ( RequestCancellation , CanceledRequests ) { // Unbounded because messages are sent in the drop fn. This is fine, because it's still // bounded by the number of in-flight requests. let ( tx , rx ) = mpsc :: unbounded_channel ( ) ; ( RequestCancellation ( tx ) , CanceledRequests ( rx ) ) }
Returns a channel to send request cancellation messages.
Returns a channel to send request cancellation messages .