一个Publisher接口是一个提供无限数量的有序元素的提供者，根据从其Subscriber(s)接收到的需求进行发布。响应调用Publisher.subscribe(Subscriber)，Subscriber上的方法的可能调用顺序。这意味着onSubscribe()方法，后跟无限数量的onNext()方法（根据Subscriber的要求），然后是onError()方法（如果有失败）或onComplete()方法（当没有更多元素可用时，只要Subscription未被取消）。
Android JNI开发入门与提高 中文WORD版
下载
本文档主要讲述的是Android JNI开发入门与提高；JNI在Android系统中有着广泛的应用。Android系统底层都是C/C++实现的，上层提供的API都是Java的，Java通过JNI调用底层的实现。比如：Android API多媒体接口MediaPlayer类，其实底层通过JNI调用libmedia库。希望本文档会给有需要的朋友带来帮助；感兴趣的朋友可以过来看看
语法
public interface Publisher{ public void subscribe(Subscriber s); }
示例
import java.util.concurrent.*; import java.util.*; import java.util.stream.*; class SimplePublisher implements Flow.Publisher{ private final Iterator iterator; SimplePublisher(int count) { this.iterator = IntStream.rangeClosed(1, count).iterator(); } @Override public void subscribe(Flow.Subscriber subscriber) { iterator.forEachRemaining(subscriber::onNext); subscriber.onComplete(); } } public class SimplePublisherImplTest { public static void main(String args[]) { new SimplePublisher(10).subscribe(new Flow.Subscriber<>() { @Override public void onSubscribe(Flow.Subscription subscription) { } @Override public void onNext(Integer item) { System.out.println("item = [" + item + "]"); } @Override public void onError(Throwable throwable) { } @Override public void onComplete() { System.out.println("complete"); } }); } }
输出
item = [1] item = [2] item = [3] item = [4] item = [5] item = [6] item = [7] item = [8] item = [9] item = [10] complete
