fn shutdown_list
	(list: &mut SmallVec<impl smallvec::Array<Item = RegisteredProtocolSubstream<NegotiatedSubstream>>>,
	cx: &mut Context)
{
	'outer: for n in (0..list.len()).rev() {
		let mut substream = list.swap_remove(n);
		loop {
			match substream.poll_next_unpin(cx) {
				Poll::Ready(Some(Ok(_))) => {}
				Poll::Pending => break,
				Poll::Ready(Some(Err(_))) | Poll::Ready(None) => continue 'outer,
			}
		}
		list.push(substream);
	}
}
/// Given a list of substreams, tries to shut them down. The substreams that have been successfully
/// shut down are removed from the list.
Given a list of substreams, tries to shut them down. The substreams that have been successfully
shut down are removed from the list.
Given a list of substreams tries to shut them down . The substreams that have been successfully shut down are removed from the list .
fn shutdown_list
	(list: &mut SmallVec<impl smallvec::Array<Item = RegisteredProtocolSubstream<NegotiatedSubstream>>>,
	cx: &mut Context)
{
	'outer: for n in (0..list.len()).rev() {
		let mut substream = list.swap_remove(n);
		loop {
			match substream.poll_next_unpin(cx) {
				Poll::Ready(Some(Ok(_))) => {}
				Poll::Pending => break,
				Poll::Ready(Some(Err(_))) | Poll::Ready(None) => continue 'outer,
			}
		}
		list.push(substream);
	}
}
fn shutdown_list ( list : & mut SmallVec < impl smallvec :: Array < Item = RegisteredProtocolSubstream < NegotiatedSubstream > > > , cx : & mut Context ) { ' outer : for n in ( 0 .. list . len ( ) ) . rev ( ) { let mut substream = list . swap_remove ( n ) ; loop { match substream . poll_next_unpin ( cx ) { Poll :: Ready ( Some ( Ok ( _ ) ) ) => { } Poll :: Pending => break , Poll :: Ready ( Some ( Err ( _ ) ) ) | Poll :: Ready ( None ) => continue ' outer , } } list . push ( substream ) ; } }
Given a list of substreams, tries to shut them down.
Given a list of substreams tries to shut them down .
list
&mut SmallVec<impl smallvec::Array<Item = RegisteredProtocolSubstream<NegotiatedSubstream>>>
cx
&mut Context
list
&mut SmallVec<impl smallvec::Array<Item = RegisteredProtocolSubstream<NegotiatedSubstream>>>
cx
&mut Context