Reactive Streams Specification

Reactive Streams는 비동기 스트림 처리를 위한 표준 규약입니다. 총 39개의 규칙으로 Publisher, Subscriber, Subscription, Processor의 동작을 정의합니다.

1. Publisher 규칙 (11개)

Rule 1.01

Publisher.subscribe가 호출되면 반드시 Subscriber.onSubscribe를 호출해야 한다.

@Override
public void subscribe(Subscriber<? super T> subscriber) {
    // 반드시 onSubscribe를 먼저 호출
    subscriber.onSubscribe(new MySubscription(subscriber));
}