 
   // Call compression_stream_process with current src, and dst set to _buf, then write output to the closure
   // Return status
-  private func process(_ finalize: Bool) throws -> compression_status {
+  private func process(finalizing finalize: Bool) throws -> compression_status {
     // Process current input, and write to buf
     _stream.dst_ptr = _buf
     _stream.dst_size = _bufCapacity


   - Throws:
   `FilterError.filterProcessError` if an error occurs during processing
   `FilterError.readCountInvalid` if `count` <= 0
   */
  public func readData(ofLength count: Int) throws -> Data? {
    // Sanity check
    guard count > 0 else { throw FilterError.readCountInvalid }

    // End reached, return early, nothing to do
    if _endReached { return nil }

    // Finalize stream
    _stream.src_size = 0
    var status = COMPRESSION_STATUS_OK
    while (status != COMPRESSION_STATUS_END) { status = try process(finalizing: true) }

    // Update state
    _finalized = true

    // Notify end of stream
    try _writeFunc(nil)
  }

  // Cleanup resources.  The filter is finalized now if it was not finalized yet.
