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