Java 9에서 Flow API를 구현하는 단계는 무엇입니까?

Java 9의

Flow API는 사실상의 표준인 Reactive Streams 사양에 해당합니다. 여기에는 비동기 게시 및 구독의 핵심을 캡처하는 최소한의 인터페이스 세트가 포함되어 있습니다.

다음은 Flow API의 주요 인터페이스입니다:

1) Flow.Publisher:구독자가 소비할 항목을 생성하며, subscribe(구독자) 메소드 하나만 포함합니다. , 그 중 목적이 분명해야 합니다.

Syntax

<strong>void subscribe(Flow.Subscriber<? super T><!--? super T--> subscriber)</strong>

2) Flow.Subscriber: 게시자(보통 하나만)를 구독하여 항목(onNext(T) 메소드를 통해), 오류 메시지(onError(Throwable)를 통해) ) 또는 더 이상 항목이 예상되지 않는다는 신호(onComplete())가 발생하기 전에 게시자는 onSubscription(Subscription) method.

Syntax

<strong>void onSubscribe(Flow.Subscription subscription)
void onNext(T item)
void onError(Throwable throwable)
void onComplete()</strong>

3) 을 호출합니다. 흐름.구독: 단일 게시자와 단일 구독자 간의 연결입니다. 구독자는 이를 사용하여 추가 항목을 요청(request(long))하거나 연결을 끊을 수 있습니다(cancel()). .

Syntax

<strong>void request(long n)
void cancel()</strong>

Flow API 실행 단계:

• 먼저 Publisher와 Subscriber를 만들어야 합니다.
• 구독자를 구독하려면 Publisher::subscribe를 사용하세요.
• Publisher는 Subscription을 생성하고 Subscriber::onSubscription을 호출하여 Subscriber가 구독을 저장할 수 있도록 합니다.
• 어떤 순간에 구독자는 Subscription::request를 호출하여 특정 수의 항목을 요청합니다.
• Publisher는 Subscriber::onNext를 호출하여 구독자에게 항목을 전달합니다. 요청한 항목 수보다 더 많은 항목을 게시하지 않습니다.
• Publisher는 어느 시점에서 문제가 발생하여 각각 Subscriber::onComplete 또는 Subscriber::onError를 호출할 수 있습니다.
• 구독자는 구독::취소를 호출하여 간격을 두고 추가 항목을 요청하거나 연결을 끊을 수 있습니다.

위 내용은 Java 9에서 Flow API를 구현하는 단계는 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!