【文件属性】:
文件名称:java后台查看所有订单源码-rxjava-walkthrough:RxJava游乐场
文件大小:45KB
文件格式:ZIP
更新时间:2024-06-25 03:14:49
系统开源
java后台查看所有订单源码RxJava
2.x
查看在
也可用于
内容
React流
Reactive
Streams
是一种编程概念,用于以非阻塞方式处理异步数据流,同时为流发布者提供背压。
它已经演变成一个基于Publisher和Subscriber
的概念。
发布者是流中事件T的来源,订阅者是这些事件的消费者。
订阅者通过调用发布者中的“工厂方法”来订阅发布者,该方法将推送流项目开始一个新的订阅:
public
interface
Publisher
{
public
void
subscribe
(
Subscriber<?
super
T
>
s
);
}
当订阅者准备好开始处理事件时,它会通过对该订阅的请求发出信号
public
interface
Subscription
{
public
void
request
(
long
n
);
//
request
n
items
public
void
cancel
();
}
收到此信号后,发布者开始为每个事件T调用Subscriber::onNext(T)
。
这一直持续到流完成(
Subsc
【文件预览】:
rxjava-walkthrough-master
----pom.xml(2KB)
----_config.yml(26B)
----src()
--------test()
----.gitignore(232B)
----README.md(74KB)