@@ -295,7 +295,6 @@ class ZstdContext : public MemoryRetainer {
   ZstdContext() = default;
 
   // Streaming-related, should be available for all compression libraries:
-  void Close();
   void SetBuffers(const char* in, uint32_t in_len, char* out, uint32_t out_len);
   void SetFlush(int flush);
   void GetAfterWriteOffsets(uint32_t* avail_in, uint32_t* avail_out) const;
@@ -320,6 +319,7 @@ class ZstdCompressContext final : public ZstdContext {
   ZstdCompressContext() = default;
 
   // Streaming-related, should be available for all compression libraries:
+  void Close();
   void DoThreadPoolWork();
   CompressionError ResetStream();
 
@@ -346,6 +346,7 @@ class ZstdDecompressContext final : public ZstdContext {
   ZstdDecompressContext() = default;
 
   // Streaming-related, should be available for all compression libraries:
+  void Close();
   void DoThreadPoolWork();
   CompressionError ResetStream();
 
@@ -1494,8 +1495,6 @@ CompressionError BrotliDecoderContext::GetErrorInfo() const {
   }
 }
 
-void ZstdContext::Close() {}
-
 void ZstdContext::SetBuffers(const char* in,
                              uint32_t in_len,
                              char* out,
@@ -1539,6 +1538,10 @@ CompressionError ZstdCompressContext::SetParameter(int key, int value) {
   return {};
 }
 
+void ZstdCompressContext::Close() {
+  cctx_.reset();
+}
+
 CompressionError ZstdCompressContext::Init(uint64_t pledged_src_size,
                                            std::string_view dictionary) {
   pledged_src_size_ = pledged_src_size;
@@ -1591,6 +1594,10 @@ CompressionError ZstdDecompressContext::SetParameter(int key, int value) {
   return {};
 }
 
+void ZstdDecompressContext::Close() {
+  dctx_.reset();
+}
+
 CompressionError ZstdDecompressContext::Init(uint64_t pledged_src_size,
                                              std::string_view dictionary) {
   dctx_.reset(ZSTD_createDCtx());