Commit 2cfac415 authored by Him188's avatar Him188

Remove redundant ListenerImpl

parent 3c818dad
...@@ -25,15 +25,6 @@ internal fun <L : Listener<E>, E : Subscribable> KClass<out E>.subscribeInternal ...@@ -25,15 +25,6 @@ internal fun <L : Listener<E>, E : Subscribable> KClass<out E>.subscribeInternal
return listener return listener
} }
/**
* 事件监听器.
*
* @author Him188moe
*/
internal sealed class ListenerImpl<in E : Subscribable> : Listener<E> {
abstract override suspend fun onEvent(event: E): ListeningStatus
}
@PublishedApi @PublishedApi
@Suppress("FunctionName") @Suppress("FunctionName")
internal fun <E : Subscribable> CoroutineScope.Handler(handler: suspend (E) -> ListeningStatus): Handler<E> { internal fun <E : Subscribable> CoroutineScope.Handler(handler: suspend (E) -> ListeningStatus): Handler<E> {
...@@ -46,7 +37,7 @@ internal fun <E : Subscribable> CoroutineScope.Handler(handler: suspend (E) -> L ...@@ -46,7 +37,7 @@ internal fun <E : Subscribable> CoroutineScope.Handler(handler: suspend (E) -> L
@PublishedApi @PublishedApi
internal class Handler<in E : Subscribable> internal class Handler<in E : Subscribable>
@PublishedApi internal constructor(parentJob: Job?, private val subscriberContext: CoroutineContext, @JvmField val handler: suspend (E) -> ListeningStatus) : @PublishedApi internal constructor(parentJob: Job?, private val subscriberContext: CoroutineContext, @JvmField val handler: suspend (E) -> ListeningStatus) :
ListenerImpl<E>(), CompletableJob by Job(parentJob) { Listener<E>, CompletableJob by Job(parentJob) {
override suspend fun onEvent(event: E): ListeningStatus { override suspend fun onEvent(event: E): ListeningStatus {
if (isCompleted || isCancelled) return ListeningStatus.STOPPED if (isCompleted || isCancelled) return ListeningStatus.STOPPED
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment