void abortForTests() throws IOException {
    if (streamer != null) {
      streamer.close();
    }
    if (response != null) {
      response.close();
    }
    closed = true;
  }
void abortForTests ( ) throws IOException { if ( streamer != null ) { streamer . close ( ) ; } if ( response != null ) { response . close ( ) ; } closed = true ; }
Harsh abort method that should only be used from tests - this
is in order to prevent pipeline recovery when eg a DN shuts down.