Início / coding / Perguntas / 77490881
Accepted
user1409534
Asked: 2023-11-16 04:57:03 +0800 CST

Como transmitir texto de um método anotado com @ShellMethod no Spring boot

  • 772

Eu uso o Spring boot 3.1.x para alguma interação com o shell. Quero transmitir texto de um método para o console.

Eu tentei algo assim:

@ShellMethod(key = "stream")
public Flux<String> streamMe(){
    List<String> cities = List.of("London", "Paris", "Rome", "Amsterdam","Boston");
    Flux<String> flux = Flux.fromIterable(cities);
    return flux.delayElements(Duration.ofSeconds(2));
}

Mas ao chamá-lo do shell recebo a saída FluxConcatMapNoPrefetch na tela

spring-boot

1 respostas

  1. Best Answer

    Spring Shell espera que os comandos sejam concluídos, para que possa imprimir o resultado no console. No entanto, quando você retorna um Flux que possui um fluxo contínuo de elementos, ele pode não se comportar conforme o esperado em um shell interativo.

    Uma maneira de imprimir o fluxo de elementos no console é inscrever-se no fluxo e tratar os resultados individualmente.

        @ShellMethod(key = "stream")
    public void streamMe() {
        List<String> cities = List.of("London", "Paris", "Rome", "Amsterdam", "Boston");
        Flux<String> flux = Flux.fromIterable(cities).delayElements(Duration.ofSeconds(2));
        flux.subscribe(
                System.out::println,
                Throwable::printStackTrace,
                () -> System.out.println("Stream completed")
        );
    }
    • 1

relate perguntas