mirror of
https://github.com/vitorpamplona/amethyst.git
synced 2025-09-28 12:59:23 +02:00
check if listeners work now
This commit is contained in:
@@ -113,7 +113,7 @@ object Client : RelayPool.Listener {
|
||||
checkNotInMainThread()
|
||||
|
||||
subscribe(
|
||||
object : Listener() {
|
||||
object : Listener {
|
||||
override fun onEvent(
|
||||
event: Event,
|
||||
subId: String,
|
||||
@@ -152,7 +152,7 @@ object Client : RelayPool.Listener {
|
||||
Log.d("sendAndWaitForResponse", "Waiting for $size responses")
|
||||
|
||||
val subscription =
|
||||
object : Listener() {
|
||||
object : Listener {
|
||||
override fun onError(
|
||||
error: Error,
|
||||
subscriptionId: String,
|
||||
@@ -363,7 +363,7 @@ object Client : RelayPool.Listener {
|
||||
|
||||
fun getSubscriptionFilters(subId: String): List<TypedFilter> = subscriptions[subId] ?: emptyList()
|
||||
|
||||
abstract class Listener {
|
||||
interface Listener {
|
||||
/** A new message was received */
|
||||
open fun onEvent(
|
||||
event: Event,
|
||||
|
@@ -67,7 +67,7 @@ abstract class NostrDataSource(
|
||||
): Int = 31 * str1.hashCode() + str2.hashCode()
|
||||
|
||||
private val clientListener =
|
||||
object : Client.Listener() {
|
||||
object : Client.Listener {
|
||||
override fun onEvent(
|
||||
event: Event,
|
||||
subscriptionId: String,
|
||||
|
Reference in New Issue
Block a user