WebFlux : Reactive Stream Specification

1. 4가지의 인터페이스가 정의되어 있다.

  1-1 Publisher

 

package org.reactivestreams;

public interface Publisher<T> {

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

 

  1-2 Subscriber

 

package org.reactivestreams;

public interface Subscriber<T> {
    public void onSubscribe(Subscription s);

    public void onNext(T t);

    public void onError(Throwable t);

    public void onComplete();
}

 

  1-3 Subscription

 

package org.reactivestreams;

public interface Subscription {

    public void request(long n);

    public void cancel();
}

 

  1-4 Processor

 

package org.reactivestreams;

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

 

2. 이벤트의 흐름이다.