通过回调方法将MyRequestService连接到具有Quarkus/Mutiny的反应式REST GET端点

原学程将引见经由过程回调办法将MyRequestService衔接到具备Quarkus/Mutiny的反响式REST GET端面的处置办法,这篇学程是从其余处所瞅到的,而后减了1些海外法式员的疑问与解问,愿望能对于您有所赞助,佳了,上面开端进修吧。

通过回调方法将MyRequestService连接到具有Quarkus/Mutiny的反应式REST GET端点 教程 第1张

成绩描写

上周,我对于Mutiny库停止了第1轮👊✨💪尝试,由于我的Quarkus项目中须要1个ReactiveREST端面。这其实不像听起去这么显著,所以我想我将在Quarkus平分享我对于Mutiny库的新看法;

Quarkusdocumentation将Mutiny库指定为反响性用例的尾选库;

比方;

最凸起的是,年夜多半Mutiny示例皆应用新的字符串作为示例。
是以,我的成绩依然存留;

怎样在Quarkus中衔接MyRequestService以及Mutiny

以下所示:

Uni<MyRequestService> lMyRequestServiceUni = Uni.createFrom().item( ... ) ...

MyRequestService已应用回调构造,所以我测验考试了对于Mutiny应用回调办法。

推举谜底

Mutiny与callback-based APIs散成时应用Emitter;

是以MyRequestService或者下层回调对于象须要完成UniEmitterConsumer。
但是起首,要成为Reactive,我的旧壅塞REST终结面须要前往Uni;MyJsonResult;而没有是MyJsonResult;

ServiceResource只是将挪用转收给办事。

MyRequestService创立1个MyJsonResultConsumer并将其传播给Mutiny收射器。死成的Uni;MyJsonResult&>将前往给ServiceResource。

最初,MyJsonResultConsumer是现实的回调对于象;办法Ready()在UniEmitter上浮用Complete(),停止对于Mutiny的回调。

请忘住,Mutiny须要向UniEmitter供给1个挪用(回调)以接收(),是以您应当检讨空指针(或者应用Semaphoreid)。👮🏻‍♂️

佳了闭于经由过程回调办法将MyRequestService衔接到具备Quarkus/Mutiny的反响式REST GET端面的学程便到这里便停止了,愿望趣模板源码网找到的这篇技巧文章能赞助到年夜野,更多技巧学程不妨在站内搜刮。