Removes sub stats from the Subscription controller to move outside.
This commit is contained in:
-2
@@ -50,7 +50,6 @@ class SubscriptionController(
|
|||||||
val client: INostrClient,
|
val client: INostrClient,
|
||||||
) {
|
) {
|
||||||
private val subscriptions = LargeCache<String, Subscription>()
|
private val subscriptions = LargeCache<String, Subscription>()
|
||||||
private val stats = SubscriptionStats()
|
|
||||||
|
|
||||||
private val clientListener =
|
private val clientListener =
|
||||||
object : IRelayClientListener {
|
object : IRelayClientListener {
|
||||||
@@ -62,7 +61,6 @@ class SubscriptionController(
|
|||||||
afterEOSE: Boolean,
|
afterEOSE: Boolean,
|
||||||
) {
|
) {
|
||||||
if (subscriptions.containsKey(subId)) {
|
if (subscriptions.containsKey(subId)) {
|
||||||
stats.add(subId, event.kind)
|
|
||||||
if (afterEOSE) {
|
if (afterEOSE) {
|
||||||
subscriptions.get(subId)?.callEose(arrivalTime, relay.url)
|
subscriptions.get(subId)?.callEose(arrivalTime, relay.url)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user