北京新情况最新消息今天_西安百度网站排名优化_北京网站建设开发公司_seo网络培训学校

public static void main(String[] args) {AtomicReference<FluxSink<String>> sendCmdRef = new AtomicReference();Flux<String> sendCmd = Flux.create(aaa -> {System.out.println("create");sendCmdRef.set(aaa);});sendCmd.doOnNext(ttt -> {System.out.println(ttt);}).doOnComplete(() -> {System.out.println("complete");}).subscribe((a) -> {System.out.println(a);});sendCmdRef.get().next("aaaa");sendCmdRef.get().next("bbb");sendCmdRef.get().complete();try {sleep(10000);} catch (InterruptedException e) {e.printStackTrace();}}