Apply review feedback for Kotlin conversion

* Use fromRunnable in updateJoin to return like other methods
* Relocate saveStreamState to group loadStreamState overloads

Signed-off-by: Aayush Gupta <contact@aayush.io>

app/src/main/java/org/schabi/newpipe/local/history/HistoryRecordManager.kt

@@ -237,20 +237,6 @@ class HistoryRecordManager(context: Context) {
             .subscribeOn(Schedulers.io())
     }
 
-    fun saveStreamState(info: StreamInfo, progressMillis: Long): Completable {
-        return Completable.fromAction {
-            runBlocking {
-                database.withWriteTransaction {
-                    val streamId = streamTable.upsert(StreamEntity(info))
-                    val state = StreamStateEntity(streamId, progressMillis)
-                    if (state.isValid(info.duration)) {
-                        streamStateTable.upsert(state)
-                    }
-                }
-            }
-        }.subscribeOn(Schedulers.io())
-    }
-
     fun loadStreamState(info: InfoItem): Maybe<StreamStateEntity> {
         return Maybe.fromCallable {
             streamTable.getStream(info.serviceId.toLong(), info.url)
@@ -281,6 +267,20 @@ class HistoryRecordManager(context: Context) {
         }.subscribeOn(Schedulers.io())
     }
 
+    fun saveStreamState(info: StreamInfo, progressMillis: Long): Completable {
+        return Completable.fromAction {
+            runBlocking {
+                database.withWriteTransaction {
+                    val streamId = streamTable.upsert(StreamEntity(info))
+                    val state = StreamStateEntity(streamId, progressMillis)
+                    if (state.isValid(info.duration)) {
+                        streamStateTable.upsert(state)
+                    }
+                }
+            }
+        }.subscribeOn(Schedulers.io())
+    }
+
     // ///////////////////////////////////////////////////////
     // Utility
     // ///////////////////////////////////////////////////////

app/src/main/java/org/schabi/newpipe/local/playlist/LocalPlaylistManager.kt

@@ -80,7 +80,7 @@ class LocalPlaylistManager(private val database: AppDatabase) {
             PlaylistStreamEntity(playlistId, streamId, index)
         }
 
-        return Completable.fromAction {
+        return Completable.fromRunnable {
             playlistStreamTable.updatePlaylistStreams(playlistId, joinEntities)
         }.subscribeOn(Schedulers.io())
     }