Revert to using Flow<T> for index loading

src/main/kotlin/framework/search/index/IndexBulkLoader.kt

@@ -1,8 +1,7 @@
 package io.github.garyttierney.ghidralite.framework.search.index
 
 import kotlinx.coroutines.flow.Flow
-import java.util.stream.Stream
 
 interface IndexBulkLoader<T : Any> {
-    suspend fun load(): Stream<T>
+    suspend fun load(): Flow<T>
 }

src/main/kotlin/framework/search/index/Indexes.kt

@@ -1,9 +1,7 @@
 package io.github.garyttierney.ghidralite.framework.search.index
 
 import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.flow.Flow
-import kotlinx.coroutines.flow.asFlow
-import kotlinx.coroutines.flow.toCollection
+import kotlinx.coroutines.flow.*
 import kotlinx.coroutines.withContext
 import java.util.concurrent.ConcurrentLinkedQueue
 import kotlin.reflect.KClass
@@ -28,13 +26,10 @@ class Indexes {
     inline fun <reified T : Any> query(): Flow<T> = query(T::class)
 
     suspend fun <T : Any> load(ty: KClass<T>, bulkLoader: IndexBulkLoader<T>) {
-        val data = withContext(Dispatchers.IO) {
-            bulkLoader.load()
-                .parallel()
-                .toList()
-        }
+        val items = mutableListOf<T>()
+        bulkLoader.load().flowOn(Dispatchers.IO).toCollection(items)
 
-        indexes[ty] = ConcurrentLinkedQueue(data)
+        indexes[ty] = ConcurrentLinkedQueue(items)
     }
 
     suspend inline fun <reified T : Any> load(bulkLoader: IndexBulkLoader<T>) {

src/main/kotlin/framework/search/index/program/ProgramDbTableLoader.kt

@@ -3,10 +3,11 @@ package io.github.garyttierney.ghidralite.framework.search.index.program
 import io.github.garyttierney.ghidralite.framework.db.GhidraRecord
 import io.github.garyttierney.ghidralite.framework.db.GhidraTable
 import io.github.garyttierney.ghidralite.framework.search.index.IndexBulkLoader
+import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.asFlow
 import kotlinx.coroutines.stream.consumeAsFlow
 import java.util.stream.Stream
 
 class ProgramDbTableLoader<T : GhidraRecord>(private val table: GhidraTable<T>, private val predicate: (T) -> Boolean = { true }) : IndexBulkLoader<T> {
-    override suspend fun load(): Stream<T> = table.all().filter(predicate)
+    override suspend fun load(): Flow<T> = table.allAfter().asFlow()
 }