从热数据源创建

Broadcaster<String> sink = Broadcaster.create(Environment.get());//1 

sink.map(String::toUpperCase) //2
    .consume(s -> System.out.printf("%s greeting = %s%n", Thread.currentThread(), s)); //3

sink.onNext("Hello World!"); //4
工厂 输入 输出 作用