 
   // 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(_ finalize: Bool) throws -> compression_status {
     // Process current input, and write to buf
     _stream.dst_ptr = _buf
     _stream.dst_size = _bufCapacity
 
     let status = compression_stream_process(&_stream, (finalize ? Int32(COMPRESSION_STREAM_FINALIZE.rawValue) : 0))
-    guard status != COMPRESSION_STATUS_ERROR else { throw FilterError.FilterProcessError }
+    guard status != COMPRESSION_STATUS_ERROR else { throw FilterError.filterProcessError }
 
     // Number of bytes written to buf
     let writtenBytes = _bufCapacity - _stream.dst_size
 
     // Write output
-    if writtenBytes > 0
-    {
+    if writtenBytes > 0 {
       let outData = Data(bytesNoCopy: _buf, count: writtenBytes, deallocator: .none)
       try _writeFunc(outData)
     }


   - Throws: `FilterError.StreamInitError` if stream initialization failed
   */
  public init(_ operation: FilterOperation,
              using algorithm : Algorithm,
              bufferCapacity : Int = 65536,
              writingTo writeFunc: @escaping (Data?) throws -> () ) throws
  {
    _stream = try compression_stream(operation: operation, algorithm: algorithm)
    _buf = UnsafeMutablePointer<UInt8>.allocate(capacity: bufferCapacity)
    _bufCapacity = bufferCapacity

   - bufferCapacity: capacity of the internal data buffer
   - readFunc: called to read the input data

   - Throws: `FilterError.filterInitError` if filter initialization failed
   */
  public init(
    _ operation: FilterOperation,
    using algorithm: Algorithm,
    bufferCapacity: Int = 65536,
    readingFrom readFunc: @escaping (Int) throws -> Data?
  ) throws {
    _stream = try compression_stream(operation: operation, algorithm: algorithm)
    _bufCapacity = bufferCapacity
    _readFunc = readFunc
