diff --git a/bag_unpacker/src/main/scala/weco/storage_service/bag_unpacker/storage/Unarchiver.scala b/bag_unpacker/src/main/scala/weco/storage_service/bag_unpacker/storage/Unarchiver.scala
index ac40f40bbd..27d0080876 100644
--- a/bag_unpacker/src/main/scala/weco/storage_service/bag_unpacker/storage/Unarchiver.scala
+++ b/bag_unpacker/src/main/scala/weco/storage_service/bag_unpacker/storage/Unarchiver.scala
@@ -73,7 +73,7 @@ object Unarchiver {
       }
 
       override def next(): (ArchiveEntry, InputStream) =
-        (latest, new CloseShieldInputStream(archiveInputStream))
+        (latest, CloseShieldInputStream.wrap(archiveInputStream))
     }
 
   private def uncompress(