registerAsyncProcessor
open fun registerAsyncProcessor(processor: Signal.Dispatch.(raw: String) -> Promise<Any?>): DisposableHandle(source)
注册一个使用异步函数(返回值为 Promise)类型 processor 的事件处理器。
processor 返回的异步结果会在当前监听函数流程内被挂起并获取。
open fun <E : Signal.Dispatch> registerAsyncProcessor(eventType: KClass<out E>, processor: E.(raw: String) -> Promise<Any?>): DisposableHandle(source)
注册一个使用异步函数(返回值为 Promise)类型 processor 的事件处理器, 并通过 KClass 对类型进行筛选。
open fun registerAsyncProcessor(processor: BiFunction<Signal.Dispatch, String, CompletionStage<Void?>>): DisposableHandle(source)
注册一个使用结果类型为 CompletionStage 的异步函数 processor 的事件处理器。
processor 返回的异步结果会在当前监听函数流程内被挂起并获取。
open fun <E : Signal.Dispatch> registerAsyncProcessor(eventType: Class<out E>, processor: BiFunction<E, String, CompletionStage<Void?>>): DisposableHandle(source)
注册一个使用结果类型为 CompletionStage 的异步函数 processor 的事件处理器, 并通过 Class 对类型进行筛选。