Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
Publisher
✓ org.reactivestreams.Publisher
Basic Publisher and Subscriber example.
import org.reactivestreams.Publisher;
import org.reactivestreams.Subscriber;
import org.reactivestreams.Subscription;
public class Quickstart {
public static void main(String[] args) {
Publisher<String> publisher = subscriber -> {
subscriber.onSubscribe(new Subscription() {
@Override
public void request(long n) {
subscriber.onNext("Hello");
subscriber.onComplete();
}
@Override
public void cancel() {}
});
};
publisher.subscribe(new Subscriber<>() {
@Override
public void onSubscribe(Subscription s) { s.request(1); }
@Override
public void onNext(String item) { System.out.println(item); }
@Override
public void onError(Throwable t) {}
@Override
public void onComplete() {}
});
}
}
Debug
Known issues
No known issues recorded.
Audit
Dependencies
No dependency data recorded yet.