Merge pull request #129 from ShapovalovaIrina/fix-input-data-for-ezst…

…d-compression

fix: convert iolist to binary for ezstd compression

src/kpro_compress.erl

@@ -88,7 +88,8 @@ java_snappy_unpack_chunks(Chunks, Acc) ->
 
 do_compress(Name, IoData) ->
     Module = get_module(Name),
-    iodata(Module:compress(IoData)).
+    Data = maybe_convert_iodata_to_binary(Module, IoData),
+    iodata(Module:compress(Data)).
 
 do_decompress(Name, Bin) ->
     Module = get_module(Name),
@@ -104,6 +105,9 @@ get_module(?zstd) ->
 get_module(Name, Default) ->
     persistent_term:get({?MODULE, Name}, Default).
 
+maybe_convert_iodata_to_binary(ezstd, IoData) -> iolist_to_binary(IoData);
+maybe_convert_iodata_to_binary(_Module, IoData) -> IoData.
+
 iodata({ok, IoData}) -> IoData;
 iodata({error, Reason}) -> error(Reason);
 iodata(IoData) when is_list(IoData) orelse is_binary(IoData) -> IoData.