WebClient中的通量与File.readLines中的通量行为不同

Flux 从文件行来看,我可以很好地处理它。当我将Flux creating函数切换到使用WebClient….get()的函数时,我会得到不同的结果;WebClient不会因为某种原因而被调用。

private Flux<String> retrieveIdListFromFile(String filename) {
  try {
    return Flux.fromIterable(Files.readAllLines(ResourceUtils.getFile(filename).toPath()));
  } catch (IOException e) {
    return Flux.error(e);
  }
}

private Flux<String> retrieveIdList() {
  return client.get()
      .uri(uriBuilder -> uriBuilder.path("capdocuments_201811v2/selectRaw")
          .queryParam("q", "-P_Id:[* TO *]")
          .queryParam("fq", "DateLastModified:[2010-01-01T00:00:00Z TO 2016-12-31T00:00:00Z]")
          .queryParam("fl", "id")
          .queryParam("rows", "10")
          .queryParam("wt", "csv")
          .build())
      .retrieve()
      .bodyToFlux(String.class);
}

当我做一个 subscribe(System.out::println) 在WebClient的流量中,什么都没有发生。当我执行blockLast()时,它会工作(调用URL,返回数据)。我不明白为什么,如何纠正,我做错了什么。 使用源于文件的流量,即使订阅也可以正常工作。我认为,通量是可以互换的。。。

当我做一个 retrieveIdList().log().subscribe() :

INFO [main] reactor.Flux.OnAssembly.1 | onSubscribe([Fuseable] FluxOnAssembly.OnAssemblySubscriber)
INFO [main] reactor.Flux.OnAssembly.1 | request(unbounded)

INFO [main] reactor.Flux.OnAssembly.1 | onSubscribe([Fuseable] FluxOnAssembly.OnAssemblySubscriber)
INFO [main] reactor.Flux.OnAssembly.1 | request(unbounded)
INFO [reactor-http-nio-4] reactor.Flux.OnAssembly.1 | onNext(id)
.
.
.