When is the deal Mono.fromCallback ? (reactive)-CodePudding

I still do not understand when to apply this method. In fact, it is similar to Mono.just, but I heard that callback is used for heavy operations if it needs to be performed separately from other flows. Now I use it like this, but is it correct.

Here is an example of use, I wrap sending a firebase notification in a callback since the operation is long

 @Override
    public Mono<NotificationDto> sendMessageAllDevice(NotificationDto notification) {
        return Mono.fromCallable(() -> fcmProvider.sendPublicMessage(notification))
                .thenReturn(notification);
    }

maybe I still had to wrap up here in Mono.just ?

CodePudding user response：

It depends which thread you want fcmProvider.sendPublicMessage(...) to be run on.

Either the one currently executing sendMessageAllDevice(...):

T result = fcmProvider.sendPublicMessage(notification);
return Mono.just(result);

Or the one(s) the underlying mono relies on:

Callable<T> callable = () -> fcmProvider.sendPublicMessage(notification);
return Mono.fromCallable(callable);

I would guess you need the latter approach.

CodePudding user response：

As you explained in the description, Mono.fromCallable is used when you want to compute a result with an async execution (mostly some heavy operation).

Since, you have already generated the Mono with Mono.fromCallable you do not have to wrap it again with Mono.just.