diff --git a/src/main/java/eu/mikroskeem/uurimustoo/algoritmidetest/algoritmid/Brotli.java b/src/main/java/eu/mikroskeem/uurimustoo/algoritmidetest/algoritmid/Brotli.java
index c9378aa..69c166a 100644
--- a/src/main/java/eu/mikroskeem/uurimustoo/algoritmidetest/algoritmid/Brotli.java
+++ b/src/main/java/eu/mikroskeem/uurimustoo/algoritmidetest/algoritmid/Brotli.java
@@ -1,10 +1,14 @@
 package eu.mikroskeem.uurimustoo.algoritmidetest.algoritmid;
 
 import lombok.Getter;
-import org.meteogroup.jbrotli.BrotliStreamCompressor;
-import org.meteogroup.jbrotli.BrotliStreamDeCompressor;
+import org.meteogroup.jbrotli.io.BrotliInputStream;
+import org.meteogroup.jbrotli.io.BrotliOutputStream;
 import org.meteogroup.jbrotli.libloader.BrotliLibraryLoader;
 
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+
 /**
  * @author Mark Vainomaa
  */
@@ -16,16 +20,12 @@ public class Brotli extends AbstractAlgorithm {
     }
 
     @Override
-    public byte[] compress(byte[] input) {
-        BrotliStreamCompressor compressor = new BrotliStreamCompressor();
-        return compressor.compressArray(input, true);
+    public OutputStream createCompressor(OutputStream outputStream) throws IOException {
+        return new BrotliOutputStream(outputStream);
     }
 
     @Override
-    public byte[] decompress(byte[] input) {
-        BrotliStreamDeCompressor decompressor = new BrotliStreamDeCompressor();
-        byte[] buf = new byte[8192]; // *sigh*
-        decompressor.deCompress(input, buf);
-        return buf;
+    public InputStream createDecompressor(InputStream inputStream) throws IOException {
+        return new BrotliInputStream(inputStream);
     }
 }