Observable<String> observable = Observable.just("Hello", "World");
observable.subscribe(s -> System.out.println(s));
Flux<String> flux = Flux.just("Hello", "World");
flux.subscribe(s -> System.out.println(s));
Source<String, NotUsed> source = Source.from(Arrays.asList("Hello", "World"));
source.runForeach(s -> System.out.println(s), materializer);
SubmissionPublisher<String> publisher = new SubmissionPublisher<>();
publisher.subscribe(new Flow.Subscriber<String>() {
public void onNext(String item) {
System.out.println(item);
}
});
publisher.submit("Hello");
