fixes #195

Author: springdoc

springdoc-openapi-webflux-core/src/main/java/org/springdoc/core/ResponseBuilder.java

@@ -2,6 +2,7 @@
 
 import com.fasterxml.jackson.annotation.JsonView;
 import io.swagger.v3.oas.models.Components;
+import io.swagger.v3.oas.models.media.ArraySchema;
 import io.swagger.v3.oas.models.media.Schema;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Component;
@@ -22,8 +23,7 @@ public ResponseBuilder(OperationBuilder operationBuilder) {
     protected Schema calculateSchemaFromParameterizedType(Components components, ParameterizedType parameterizedType,
                                                           JsonView jsonView) {
         Schema schemaN = null;
-        if (Mono.class.getName().contentEquals(parameterizedType.getRawType().getTypeName())
-                || Flux.class.getName().contentEquals(parameterizedType.getRawType().getTypeName())) {
+        if (Mono.class.getName().contentEquals(parameterizedType.getRawType().getTypeName())) {
             if (parameterizedType.getActualTypeArguments()[0] instanceof ParameterizedType && ResponseEntity.class
                     .getName().contentEquals(((ParameterizedType) parameterizedType.getActualTypeArguments()[0])
                             .getRawType().getTypeName())) {
@@ -33,8 +33,23 @@ protected Schema calculateSchemaFromParameterizedType(Components components, Par
             } else {
                 schemaN = calculateSchemaParameterizedType(components, parameterizedType, jsonView);
             }
+        } else if (Flux.class.getName().contentEquals(parameterizedType.getRawType().getTypeName())) {
+            if (parameterizedType.getActualTypeArguments()[0] instanceof ParameterizedType && ResponseEntity.class
+                    .getName().contentEquals(((ParameterizedType) parameterizedType.getActualTypeArguments()[0])
+                            .getRawType().getTypeName())) {
+                ParameterizedType parameterizedTypeNew = (ParameterizedType) parameterizedType
+                        .getActualTypeArguments()[0];
+                schemaN = calculateFluxSchema(components, parameterizedTypeNew, jsonView);
+            } else {
+                schemaN = calculateFluxSchema(components, parameterizedType, jsonView);
+            }
         }
         return schemaN;
     }
 
+    private Schema calculateFluxSchema(Components components, ParameterizedType parameterizedType, JsonView jsonView) {
+        Schema itemsSchema = SpringDocAnnotationsUtils.extractSchema(components, parameterizedType.getActualTypeArguments()[0], jsonView);
+        return new ArraySchema().items(itemsSchema);
+    }
+
 }