nick/amethyst
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Exposes the sample rate on BaseEoseManager class

Browse Source
This commit is contained in:
Vitor Pamplona
2025-10-02 17:50:33 -04:00
parent 5f83379459
commit 1b36d7e189
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
amethyst/src/main/java/com/vitorpamplona/amethyst/service/relayClient/eoseManagers/BaseEoseManager.kt
+2 -1
View File
@@ -40,6 +40,7 @@ interface IEoseManager {
abstract class BaseEoseManager<T>( abstract class BaseEoseManager<T>(
val client: INostrClient, val client: INostrClient,
val allKeys: () -> Set<T>, val allKeys: () -> Set<T>,
val sampleTime: Long = 500,
) : IEoseManager { ) : IEoseManager {
protected val logTag: String = this.javaClass.simpleName protected val logTag: String = this.javaClass.simpleName
@@ -58,7 +59,7 @@ abstract class BaseEoseManager<T>(
fun dismissSubscription(subId: String) = orchestrator.dismissSubscription(subId) fun dismissSubscription(subId: String) = orchestrator.dismissSubscription(subId)
// Refreshes observers in batches. // Refreshes observers in batches.
private val bundler = BundledUpdate(500, Dispatchers.Default) private val bundler = BundledUpdate(sampleTime, Dispatchers.Default)
override fun invalidateFilters(ignoreIfDoing: Boolean) { override fun invalidateFilters(ignoreIfDoing: Boolean) {
bundler.invalidate(ignoreIfDoing, ::forceInvalidate) bundler.invalidate(ignoreIfDoing, ::forceInvalidate)