ext/zstdruby/streaming_decompress.c in zstd-ruby-1.5.6.2 vs ext/zstdruby/streaming_decompress.c in zstd-ruby-1.5.6.3
- old
+ new
@@ -102,10 +102,10 @@
TypedData_Get_Struct(obj, struct streaming_decompress_t, &streaming_decompress_type, sd);
const char* output_data = RSTRING_PTR(sd->buf);
VALUE result = rb_str_new(0, 0);
while (input.pos < input.size) {
ZSTD_outBuffer output = { (void*)output_data, sd->buf_size, 0 };
- size_t const ret = ZSTD_decompressStream(sd->dctx, &output, &input);
+ size_t const ret = zstd_decompress(sd->dctx, &output, &input, false);
if (ZSTD_isError(ret)) {
rb_raise(rb_eRuntimeError, "decompress error error code: %s", ZSTD_getErrorName(ret));
}
rb_str_cat(result, output.dst, output.pos);
}