↓ 8 callersMethodsubscribepublish到某subscriber just,map,reduce,produce可以生成subscriber,这个是直接指定subscriber @param subscriber 订阅者
app-builder/waterflow/java/waterflow-service/src/main/java/modelengine/fit/waterflow/flowsengine/domain/flows/streams/From.java:367