Closes subscriptions regardless with they are active or not.

This commit is contained in:
Vitor Pamplona
2023-02-18 19:06:39 -05:00
parent ccd6beee8e
commit d2c39b022b
@@ -131,12 +131,10 @@ abstract class NostrDataSource(val debugName: String) {
open fun stop() { open fun stop() {
subscriptions.values.forEach { channel -> subscriptions.values.forEach { channel ->
if (channel.typedFilters != null) {// if it is active, close
Client.close(channel.id) Client.close(channel.id)
channel.typedFilters = null channel.typedFilters = null
} }
} }
}
fun requestNewChannel(onEOSE: ((Long) -> Unit)? = null): Subscription { fun requestNewChannel(onEOSE: ((Long) -> Unit)? = null): Subscription {
val newSubscription = Subscription(UUID.randomUUID().toString().substring(0,4), onEOSE) val newSubscription = Subscription(UUID.randomUUID().toString().substring(0,4), onEOSE)