public Mono listEventTypes()

in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventTypeController.java [47:71]

• 24 lines of code
• 1 McCabe index (conditional complexity)

    public Mono<ListEventTypesResponse> listEventTypes(@RequestBody ListEventTypesRequest listEventTypesRequest) {
        return Mono.subscriberContext()
            .map(ctx -> {
                PaginationResult<List<EventType>> paginationResult = eventTypeService.listEventTypes(
                    accountAPI.getResourceOwnerAccountId(ctx), listEventTypesRequest.getEventBusName(),
                    listEventTypesRequest.getEventSourceName(), listEventTypesRequest.getNextToken(),
                    listEventTypesRequest.getMaxResults());

                List<EventTypeDTO> eventTypeDTOS = Lists.newArrayList();
                paginationResult.getData()
                    .forEach(eventType -> {
                        EventTypeDTO eventTypeDTO = EventTypeDTO.builder()
                            .eventBusName(eventType.getEventBusName())
                            .eventSourceName(eventType.getEventSourceName())
                            .eventTypeName(eventType.getName())
                            .description(eventType.getDescription())
                            .gmtCreate(eventType.getGmtCreate())
                            .gmtModify(eventType.getGmtModify())
                            .build();
                        eventTypeDTOS.add(eventTypeDTO);
                    });
                return new ListEventTypesResponse(eventTypeDTOS, paginationResult.getNextToken(),
                    paginationResult.getTotal(), listEventTypesRequest.getMaxResults());
            });
    }