public class DefaultAsyncEvent extends Object implements AsyncEvent
| Constructor and Description |
|---|
DefaultAsyncEvent() |
| Modifier and Type | Method and Description |
|---|---|
void |
async(org.reactivestreams.Publisher<?> publisher)
注册一个异步任务
|
void |
first(org.reactivestreams.Publisher<?> publisher)
注册一个优先级高的任务
|
reactor.core.publisher.Mono<Void> |
getAsync() |
boolean |
hasListener() |
reactor.core.publisher.Mono<Void> |
publish(org.springframework.context.ApplicationEventPublisher eventPublisher)
推送事件到 ApplicationEventPublisher
|
public void async(org.reactivestreams.Publisher<?> publisher)
AsyncEventasync in interface AsyncEventpublisher - 异步任务public void first(org.reactivestreams.Publisher<?> publisher)
AsyncEventfirst in interface AsyncEventpublisher - 任务public reactor.core.publisher.Mono<Void> getAsync()
getAsync in interface AsyncEventpublic reactor.core.publisher.Mono<Void> publish(org.springframework.context.ApplicationEventPublisher eventPublisher)
AsyncEventpublish in interface AsyncEventeventPublisher - ApplicationEventPublisherpublic boolean hasListener()
Copyright © 2016–2021. All rights reserved.