Remove SuspendingCloseable (readium#532)

Author: qnga

readium/adapters/pdfium/document/src/main/java/org/readium/adapter/pdfium/document/PdfiumDocument.kt

@@ -72,7 +72,7 @@ public class PdfiumDocument(
         core.getTableOfContents(document).map { it.toOutlineNode() }
     }
 
-    override suspend fun close() {
+    override fun close() {
         tryOrLog {
             core.closeDocument(document)
         }

readium/adapters/pspdfkit/document/src/main/java/org/readium/adapter/pspdfkit/document/PsPdfKitDocument.kt

@@ -115,7 +115,7 @@ public class PsPdfKitDocument(
         document.outline.toOutlineNodes()
     }
 
-    override suspend fun close() {}
+    override fun close() {}
 }
 
 private fun List<OutlineElement>.toOutlineNodes(): List<PdfDocument.OutlineNode> =

readium/shared/src/main/java/org/readium/r2/shared/publication/Publication.kt

@@ -199,7 +199,7 @@ public class Publication(
     /**
      * Closes any opened resource associated with the [Publication], including services.
      */
-    override suspend fun close() {
+    override fun close() {
         container.close()
         services.close()
     }

readium/shared/src/main/java/org/readium/r2/shared/publication/PublicationServicesHolder.kt

@@ -11,12 +11,12 @@ package org.readium.r2.shared.publication
 import kotlin.reflect.KClass
 import org.readium.r2.shared.InternalReadiumApi
 import org.readium.r2.shared.extensions.tryOrLog
-import org.readium.r2.shared.util.SuspendingCloseable
+import org.readium.r2.shared.util.Closeable
 
 /**
  * Holds [Publication.Service] instances for a [Publication].
  */
-public interface PublicationServicesHolder : SuspendingCloseable {
+public interface PublicationServicesHolder : Closeable {
     /**
      * Returns the first publication service that is an instance of [serviceType].
      */
@@ -37,7 +37,7 @@ internal class ListPublicationServicesHolder(
     override fun <T : Publication.Service> findServices(serviceType: KClass<T>): List<T> =
         services.filterIsInstance(serviceType.java)
 
-    override suspend fun close() {
+    override fun close() {
         for (service in services) {
             tryOrLog { service.close() }
         }

readium/shared/src/main/java/org/readium/r2/shared/publication/services/search/SearchService.kt

@@ -12,8 +12,8 @@ import org.readium.r2.shared.ExperimentalReadiumApi
 import org.readium.r2.shared.publication.LocatorCollection
 import org.readium.r2.shared.publication.Publication
 import org.readium.r2.shared.publication.ServiceFactory
+import org.readium.r2.shared.util.Closeable
 import org.readium.r2.shared.util.Error
-import org.readium.r2.shared.util.SuspendingCloseable
 import org.readium.r2.shared.util.Try
 import org.readium.r2.shared.util.data.ReadError
 
@@ -134,7 +134,7 @@ public var Publication.ServicesBuilder.searchServiceFactory: ServiceFactory?
  * Iterates through search results.
  */
 @ExperimentalReadiumApi
-public interface SearchIterator : SuspendingCloseable {
+public interface SearchIterator : Closeable {
 
     /**
      * Number of matches for this search, if known.
@@ -157,7 +157,7 @@ public interface SearchIterator : SuspendingCloseable {
      * Closes any resources allocated for the search query, such as a cursor.
      * To be called when the user dismisses the search.
      */
-    override suspend fun close() {}
+    override fun close() {}
 
     /**
      * Performs the given operation on each result page of this [SearchIterator].

readium/shared/src/main/java/org/readium/r2/shared/util/Closeable.kt

@@ -17,23 +17,11 @@ public interface Closeable {
     public fun close()
 }
 
-/**
- * A [SuspendingCloseable] is an object holding closeable resources, such as open files or streams.
- */
-public interface SuspendingCloseable {
-
-    /**
-     * Closes this object and releases any resources associated with it.
-     * If the object is already closed then invoking this method has no effect.
-     */
-    public suspend fun close()
-}
-
 /**
  * Executes the given block function on this resource and then closes it down correctly whether
  * an exception is thrown or not.
  */
-public suspend inline fun <T : SuspendingCloseable?, R> T.use(block: (T) -> R): R {
+public inline fun <T : Closeable?, R> T.use(block: (T) -> R): R {
     var exception: Throwable? = null
     try {
         return block(this)

readium/shared/src/main/java/org/readium/r2/shared/util/asset/Asset.kt

@@ -6,15 +6,15 @@
 
 package org.readium.r2.shared.util.asset
 
-import org.readium.r2.shared.util.SuspendingCloseable
+import org.readium.r2.shared.util.Closeable
 import org.readium.r2.shared.util.data.Container
 import org.readium.r2.shared.util.format.Format
 import org.readium.r2.shared.util.resource.Resource
 
 /**
  * An asset which is either a single resource or a container that holds multiple resources.
  */
-public sealed class Asset : SuspendingCloseable {
+public sealed class Asset : Closeable {
 
     /**
      * Format of the asset.
@@ -33,7 +33,7 @@ public class ContainerAsset(
     public val container: Container<Resource>
 ) : Asset() {
 
-    override suspend fun close() {
+    override fun close() {
         container.close()
     }
 }
@@ -49,7 +49,7 @@ public class ResourceAsset(
     public val resource: Resource
 ) : Asset() {
 
-    override suspend fun close() {
+    override fun close() {
         resource.close()
     }
 }

readium/shared/src/main/java/org/readium/r2/shared/util/cache/Cache.kt

@@ -16,7 +16,6 @@ import kotlinx.coroutines.sync.withLock
 import org.readium.r2.shared.InternalReadiumApi
 import org.readium.r2.shared.util.Closeable
 import org.readium.r2.shared.util.MemoryObserver
-import org.readium.r2.shared.util.SuspendingCloseable
 import org.readium.r2.shared.util.Try
 
 /**
@@ -25,7 +24,7 @@ import org.readium.r2.shared.util.Try
  * It implements [MemoryObserver] to flush unused in-memory objects when necessary.
  */
 @InternalReadiumApi
-public interface Cache<V> : SuspendingCloseable, MemoryObserver {
+public interface Cache<V> : Closeable, MemoryObserver {
     /**
      * Performs an atomic [block] transaction on this cache.
      */
@@ -111,11 +110,13 @@ public class InMemoryCache<V> : Cache<V> {
         }
     }
 
-    override suspend fun close() {
-        transaction {
-            for ((_, value) in values) {
-                (value as? Closeable)?.close()
-                (value as? SuspendingCloseable)?.close()
+    @OptIn(DelicateCoroutinesApi::class)
+    override fun close() {
+        GlobalScope.launch {
+            transaction {
+                for ((_, value) in values) {
+                    (value as? Closeable)?.close()
+                }
             }
         }
     }

readium/shared/src/main/java/org/readium/r2/shared/util/content/ContentResource.kt

@@ -47,7 +47,7 @@ public class ContentResource(
 
     override val sourceUrl: AbsoluteUrl? = uri.toUrl() as? AbsoluteUrl
 
-    override suspend fun close() {
+    override fun close() {
     }
 
     override suspend fun properties(): Try<Resource.Properties, ReadError> {

readium/shared/src/main/java/org/readium/r2/shared/util/data/Caching.kt

@@ -58,7 +58,7 @@ internal class CachingReadable(
         }
     }
 
-    override suspend fun close() {}
+    override fun close() {}
 }
 
 internal class CachingContainer(
@@ -81,7 +81,7 @@ internal class CachingContainer(
         return blobContext
     }
 
-    override suspend fun close() {
+    override fun close() {
         cache.forEach { it.value.close() }
         cache.clear()
     }