리액티브 스트림은 리액티브 프로그래밍을 위한 명세이다. 비즈니스 시스템 개발자는 리액티브 스트림에 정의된 인터페이스를 구현하면, 리액티브 프로그래밍을 구현할 수 있다.

리액티브 스트림 인터페이스

리액티브 스트림의 인터페이스는 다음과 같다.

• Processor
  • Publisher, Subscriber의 기능이 모두 있음.
• Publisher
  • 데이터를 생성하고 통지한다.
  • 데이터를 생성하고 발행하는 subscribe()함수를 구현해야 한다.
• Subscriber
  • 통지된 데이터를 전달받아 처리한다
  • onSubscribe() : 데이터를 최초 통지할 때 호출되는 함수
  • onNext() : 데이터를 통지할 때 호출되는 함수
  • onError() : 데이터 통지 중 에러발생시 호출되는 함수
  • onComplete() : 데이터 통지가 끝났음을 알리는 함수
• Subscription
  • 전달받을 데이터의 개수를 요청하고 구독을 해지한다
  • request() : 데이터 구독 요청(데이터 개수 파라미터)
  • cancel() : 데이터 구독 취소

인터페이스 클래스 다이어그램

아래는 리액티브 스트림에 정의되어있는 코드이다.

public interface Processor<T, R> extends Subscriber<T>, Publisher<R> {}

public interface Publisher<T> {

    public void subscribe(Subscriber<? super T> s);

}

public interface Subscriber<T> {

    public void onSubscribe(Subscription s);

    public void onNext(T t);

    public void onError(Throwable t);

    public void onComplete();

}

public interface Subscription {

    public void request(long n);

    public void cancel();

}

→ 리액티브 스트림은 명세를 정의할 뿐 실제로 구현체를 만들어 사용해야한다.

위 명세를 보면 알겠지만, 리액티브 스트림의 기본적 흐름은 다음과 같다.

1. Subscriber가 Publisher에게 subscribe하면, Publisher가 데이터 또는 시퀀스를 전달하게 된다.
2. 전달 전 Publisher는 Subscribe에 정의된 onSubscribe를 호출한다
3. Subscriber는 Request를 호출한다
4. Publisher는 데이터를 Subscriber에게 전달하고, onError() 혹은 onComplete를 호출한다.