pub async fn handle_requests_for_stream(request_stream: AuthProviderRequestStream) {
        request_stream
            .try_for_each(|r| future::ready(Self::handle_request(r)))
            .unwrap_or_else(|e| warn!("Error running AuthProvider{:?}", e))
            .await;
    }
/// Handles requests received over the given `request_stream`.
Handles requests received over the given `request_stream`.
Handles requests received over the given ` request_stream ` .
pub async fn handle_requests_for_stream(request_stream: AuthProviderRequestStream) {
        request_stream
            .try_for_each(|r| future::ready(Self::handle_request(r)))
            .unwrap_or_else(|e| warn!("Error running AuthProvider{:?}", e))
            .await;
    }
pub async fn handle_requests_for_stream ( request_stream : AuthProviderRequestStream ) { request_stream . try_for_each ( | r | future :: ready ( Self :: handle_request ( r ) ) ) . unwrap_or_else ( | e | warn ! ( " " e ) ) . await ; }
Handles requests received over the given `request_stream`.
Handles requests received over the given ` request_stream ` .
request_stream
AuthProviderRequestStream