fn poll_unblocked(&mut self) -> Option<StreamId> {
        if self.flow_blocked() {
            // Everything's still blocked
            return None;
        }

        while let Some(id) = self.connection_blocked.pop() {
            let stream = match self.send.get_mut(&id) {
                None => continue,
                Some(s) => s,
            };
            debug_assert!(stream.connection_blocked);
            stream.connection_blocked = false;
            // If it's no longer sensible to write to a stream (even to detect an error) then don't
            // report it.
            if stream.is_writable() {
                return Some(id);
            }
        }

        None
    }
/// Fetch a stream for which a write previously failed due to *connection-level* flow control or
/// send window limits which no longer apply.
Fetch a stream for which a write previously failed due to *connection-level* flow control or
send window limits which no longer apply.
Fetch a stream for which a write previously failed due to * connection - level * flow control or send window limits which no longer apply .
fn poll_unblocked(&mut self) -> Option<StreamId> {
        if self.flow_blocked() {
            // Everything's still blocked
            return None;
        }
        while let Some(id) = self.connection_blocked.pop() {
            let stream = match self.send.get_mut(&id) {
                None => continue,
                Some(s) => s,
            };
            debug_assert!(stream.connection_blocked);
            stream.connection_blocked = false;
            // If it's no longer sensible to write to a stream (even to detect an error) then don't
            // report it.
            if stream.is_writable() {
                return Some(id);
            }
        }
        None
    }
fn poll_unblocked ( & mut self ) -> Option < StreamId > { if self . flow_blocked ( ) { // Everything's still blocked return None ; } while let Some ( id ) = self . connection_blocked . pop ( ) { let stream = match self . send . get_mut ( & id ) { None => continue , Some ( s ) => s , } ; debug_assert ! ( stream connection_blocked ) ; stream . connection_blocked = false ; // If it's no longer sensible to write to a stream (even to detect an error) then don't // report it. if stream . is_writable ( ) { return Some ( id ) ; } } None }
Fetch a stream for which a write previously failed due to *connection-level* flow control or
send window limits which no longer apply.
Fetch a stream for which a write previously failed due to * connection - level * flow control or send window limits which no longer apply .
&mut self