close

open suspend fun close(hadNonzeroRecords: Boolean, streamFailure: StreamProcessingFailed? = null)