@ GuardedBy ( "lock" ) private boolean startPendingStreams ( ) { boolean hasStreamStarted = false ; while ( ! pendingStreams . isEmpty ( ) && streams . size ( ) < maxConcurrentStreams ) { OkHttpClientStream stream = pendingStreams . poll ( ) ; startStream ( stream ) ; hasStreamStarted = true ; } return hasStreamStarted ; }
Starts pending streams returns true if at least one pending stream is started .