import java.util.concurrent.Flow.*;
public class ReactiveCollectionExample {
public static void main(String[] args) {
}
private static Publisher<Integer> getPublisher() {
Flow.Publisher<Integer> publisher = new Flow.Publisher<Integer>() {
public void subscribe(Subscriber<? super Integer> subscriber) {
subscriber.onNext(2);
subscriber.onNext(3);
}
};
return publisher;
}
private static Subscriber<Integer> getSubscriber() {
return new Subscriber<Integer>() {
public void onSubscribe(Subscription subscription) {
}
public void onNext(Integer item) {
}
public void onError(Throwable throwable) {
throwable.printStackTrace();
}
public void onComplete() {
}
};
}
}
