void awaitAllAcksReceived(IgniteUuid fileId) throws IgniteInterruptedCheckedException {
  WriteCompletionFuture fut=pendingWrites.get(fileId);
  if (fut != null)   fut.awaitAllAcksReceived();
}

void awaitAllAcksReceived ( IgniteUuid fileId ) throws IgniteInterruptedCheckedException { WriteCompletionFuture fut = pendingWrites . get ( fileId ) ; if ( fut != null ) fut . awaitAllAcksReceived ( ) ; }
allows output stream to await for all current acks .
