Java Reactor：如何从stdin生成Flux？

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Java Reactor：如何从stdin生成Flux？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含859字，纯文字阅读大概需要2分钟。

内容图文

我想异步读取用户从stdin生成的消息.
就像是：

Flux.from(stdinPublisher()) 
    .subscribe(msg -> System.out.println("Received: " + msg));

那么如何在这里实现这样的stdin发布者呢？

解决方法:

很容易.对不起打扰:)

import java.util.Scanner;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;
import reactor.core.publisher.Flux;

@Component
@Slf4j
public class StdinProducerExample implements ApplicationRunner {

  @Override
  public void run(ApplicationArguments args) throws Exception {
    Flux
        .create(sink -> {
          Scanner scanner = new Scanner(System.in);
          while (scanner.hasNext()) {
            sink.next(scanner.nextLine());
          }
        })
        .subscribeOn(Schedulers.newSingle("stdin publisher"))
        .subscribe(m -> log.info("User message: {}", m));
    log.info("Started listening stdin");
  }

}

内容总结

以上是互联网集市为您收集整理的Java Reactor：如何从stdin生成Flux？全部内容，希望文章能够帮你解决Java Reactor：如何从stdin生成Flux？所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---