Removes stats from Orchestrator to move out of the inner classes and be an option for app developers instead.
This commit is contained in:
-2
@@ -26,6 +26,4 @@ interface ComposeSubscriptionManagerControls {
|
|||||||
fun invalidateFilters()
|
fun invalidateFilters()
|
||||||
|
|
||||||
fun destroy()
|
fun destroy()
|
||||||
|
|
||||||
fun printStats()
|
|
||||||
}
|
}
|
||||||
|
|||||||
-4
@@ -33,8 +33,6 @@ interface IEoseManager {
|
|||||||
fun invalidateFilters(ignoreIfDoing: Boolean = false)
|
fun invalidateFilters(ignoreIfDoing: Boolean = false)
|
||||||
|
|
||||||
fun destroy()
|
fun destroy()
|
||||||
|
|
||||||
fun printStats()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
abstract class BaseEoseManager<T>(
|
abstract class BaseEoseManager<T>(
|
||||||
@@ -48,8 +46,6 @@ abstract class BaseEoseManager<T>(
|
|||||||
|
|
||||||
abstract fun updateSubscriptions(keys: Set<T>)
|
abstract fun updateSubscriptions(keys: Set<T>)
|
||||||
|
|
||||||
override fun printStats() = orchestrator.printStats(logTag)
|
|
||||||
|
|
||||||
fun newSubscriptionId() = if (isDebug) logTag + newSubId() else newSubId()
|
fun newSubscriptionId() = if (isDebug) logTag + newSubId() else newSubId()
|
||||||
|
|
||||||
fun getSubscription(subId: String) = orchestrator.getSub(subId)
|
fun getSubscription(subId: String) = orchestrator.getSub(subId)
|
||||||
|
|||||||
-2
@@ -99,6 +99,4 @@ class RelaySubscriptionsCoordinator(
|
|||||||
)
|
)
|
||||||
|
|
||||||
fun destroy() = all.forEach { it.destroy() }
|
fun destroy() = all.forEach { it.destroy() }
|
||||||
|
|
||||||
fun printCounters() = all.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -56,6 +56,4 @@ class AccountFilterAssembler(
|
|||||||
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -49,6 +49,4 @@ class ChannelFinderFilterAssemblyGroup(
|
|||||||
override fun invalidateKeys() = invalidateFilters()
|
override fun invalidateKeys() = invalidateFilters()
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -47,6 +47,4 @@ class EventFinderFilterAssembler(
|
|||||||
override fun invalidateKeys() = invalidateFilters()
|
override fun invalidateKeys() = invalidateFilters()
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -46,6 +46,4 @@ class NWCPaymentFilterAssembler(
|
|||||||
override fun invalidateKeys() = invalidateFilters()
|
override fun invalidateKeys() = invalidateFilters()
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -49,6 +49,4 @@ class UserFinderFilterAssembler(
|
|||||||
override fun invalidateKeys() = invalidateFilters()
|
override fun invalidateKeys() = invalidateFilters()
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -54,6 +54,4 @@ class SearchFilterAssembler(
|
|||||||
override fun invalidateKeys() = invalidateFilters()
|
override fun invalidateKeys() = invalidateFilters()
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -99,7 +99,6 @@ class MainActivity : AppCompatActivity() {
|
|||||||
@OptIn(DelicateCoroutinesApi::class)
|
@OptIn(DelicateCoroutinesApi::class)
|
||||||
GlobalScope.launch(Dispatchers.IO) {
|
GlobalScope.launch(Dispatchers.IO) {
|
||||||
debugState(this@MainActivity)
|
debugState(this@MainActivity)
|
||||||
Amethyst.instance.sources.printCounters()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
super.onPause()
|
super.onPause()
|
||||||
|
|||||||
-2
@@ -46,6 +46,4 @@ class ChatroomFilterAssembler(
|
|||||||
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -49,6 +49,4 @@ class ChannelFilterAssembler(
|
|||||||
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -44,6 +44,4 @@ class ChatroomListFilterAssembler(
|
|||||||
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -42,6 +42,4 @@ class CommunityFilterAssembler(
|
|||||||
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -48,6 +48,4 @@ class DiscoveryFilterAssembler(
|
|||||||
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -50,6 +50,4 @@ class GeoHashFilterAssembler(
|
|||||||
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -45,6 +45,4 @@ class HashtagFilterAssembler(
|
|||||||
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -53,6 +53,4 @@ class HomeFilterAssembler(
|
|||||||
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -47,6 +47,4 @@ class UserProfileFilterAssembler(
|
|||||||
override fun invalidateKeys() = invalidateFilters()
|
override fun invalidateKeys() = invalidateFilters()
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -47,6 +47,4 @@ class ThreadFilterAssembler(
|
|||||||
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -47,6 +47,4 @@ class VideoFilterAssembler(
|
|||||||
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
override fun invalidateFilters() = group.forEach { it.invalidateFilters() }
|
||||||
|
|
||||||
override fun destroy() = group.forEach { it.destroy() }
|
override fun destroy() = group.forEach { it.destroy() }
|
||||||
|
|
||||||
override fun printStats() = group.forEach { it.printStats() }
|
|
||||||
}
|
}
|
||||||
|
|||||||
-2
@@ -88,8 +88,6 @@ class SubscriptionController(
|
|||||||
client.unsubscribe(clientListener)
|
client.unsubscribe(clientListener)
|
||||||
}
|
}
|
||||||
|
|
||||||
fun printStats(tag: String) = stats.printCounter(tag)
|
|
||||||
|
|
||||||
fun getSub(subId: String) = subscriptions.get(subId)
|
fun getSub(subId: String) = subscriptions.get(subId)
|
||||||
|
|
||||||
fun requestNewSubscription(
|
fun requestNewSubscription(
|
||||||
|
|||||||
Reference in New Issue
Block a user