class ActionReturnReactiveHandler implements ActionReturnHandler {
    @Override
    public boolean matched(Class<?> returnType) {
        return Publisher.class.isAssignableFrom(returnType);
    }

    @Override
    public void returnHandle(Context ctx, Action action, Object result) throws Throwable {<FILL_FUNCTION_BODY>}
}

        if (result != null) {
            if (ctx.asyncSupported() == false) {
                throw new IllegalStateException("This boot plugin does not support asynchronous mode");
            }

            ((Publisher) result).subscribe(new ActionReactiveSubscriber(ctx, action));
        }
    
<no_super_class>