public void run ( ) { try { callback . open ( ) ; this . request = getLogRequest ( true ) ; final HttpResponse response = client . execute ( request ) ; parseResponse ( response ) ; } catch ( LogCallback . DoneException e ) { // Signifies we're finished with the log stream. } catch ( IOException e ) { callback . error ( "IO Error while requesting logs: " + e + " " + Thread . currentThread ( ) . getName ( ) ) ; } finally { callback . close ( ) ; } }
Fetch log asynchronously as stream and follow stream