Apakah langkah-langkah untuk melaksanakan Flow API dalam Java 9?

Flow API sepadan dengan spesifikasi Reactive Streams dalam Java 9, yang merupakan standard de facto. Ia mengandungi set antara muka minimum yang menangkap teras penerbitan dan langganan tak segerak.

Berikut ialah antara muka utama Flow API:

1) Flow.Penerbit:Ia menjana item untuk digunakan oleh pelanggan, dan ia hanya mengandungi satu kaedah: subscriber) , antaranya Tujuannya hendaklah jelas.

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

Salin selepas log masuk

2) Flow.Pelanggan: Ia melanggan penerbit (biasanya hanya satu) untuk menerima item (melalui kaedah onNext(T)(Throwable), mesej ralat ), atau isyarat bahawa tiada lagi item akan dijangkakan (onComplete() Sebelum mana-mana perkara itu berlaku, penerbit memanggil onSubscription(Langganan) kaedah.Syntax

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

Aliran.Langganan: Sambungan antara penerbit tunggal dan seorang pelanggan Pelanggan boleh menggunakannya untuk meminta lebih banyak item (permintaan(panjang)) atau memutuskan sambungan (batal()). .Syntax

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

Pertama, kita perlu mencipta

dan
• .Subscriber Gunakan Penerbit::subscribe
untuk Langgan Pelanggan.
• Penerbit mencipta Langganan
dan memanggil Pelanggan::onSubscription supaya Pelanggan boleh menyimpan langganan.
• Pada masa tertentu, Pelanggan menghubungi Langganan::permintaan untuk meminta bilangan item tertentu.
Penerbit menghantar item kepada Pelanggan dengan menghubungi Subscriber::onNext. Ia tidak akan menerbitkan lebih daripada bilangan item yang diminta.
• Penerbit mungkin menghadapi masalah pada satu ketika dan masing-masing menghubungi Subscriber::onComplete atau Subscriber::onError.
• Pelanggan boleh meminta lebih banyak item pada selang waktu atau memutuskan sambungan dengan menghubungi Langganan::batal.

Atas ialah kandungan terperinci Apakah langkah-langkah untuk melaksanakan Flow API dalam Java 9?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!