|
|
@@ -161,11 +161,11 @@ internal fun Method.registerEvent(
|
|
|
if (annotation.ignoreCancelled) {
|
|
|
if ((this as? CancellableEvent)?.isCancelled != true) {
|
|
|
withContext(Dispatchers.IO) {
|
|
|
- [email protected](owner, this)
|
|
|
+ [email protected](owner, this@subscribeAlways)
|
|
|
}
|
|
|
}
|
|
|
} else withContext(Dispatchers.IO) {
|
|
|
- [email protected](owner, this)
|
|
|
+ [email protected](owner, this@subscribeAlways)
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -179,11 +179,11 @@ internal fun Method.registerEvent(
|
|
|
if (annotation.ignoreCancelled) {
|
|
|
if ((this as? CancellableEvent)?.isCancelled != true) {
|
|
|
withContext(Dispatchers.IO) {
|
|
|
- [email protected](owner, this) as ListeningStatus
|
|
|
+ [email protected](owner, this@subscribe) as ListeningStatus
|
|
|
}
|
|
|
} else ListeningStatus.LISTENING
|
|
|
} else withContext(Dispatchers.IO) {
|
|
|
- [email protected](owner, this) as ListeningStatus
|
|
|
+ [email protected](owner, this@subscribe) as ListeningStatus
|
|
|
}
|
|
|
|
|
|
}
|