【文件属性】：
文件名称：rxfire:gemfire 的响应式扩展
文件大小：64KB
文件格式：ZIP
更新时间：2021-06-13 18:50:33
Java
火
gemfire 的响应式扩展
关于如何将连续查询支持转换为流的代码
要运行，只需启动 /server 子项目上的 gemfire 服务器：
./gradlew :server:bootRun
在流聚合器上运行测试以验证结果。
这里真正值得的是：
public class SubscriberEventAdapter implements EventAdapter {
final Subscriber subscriber;
public SubscriberEventAdapter ( Subscriber subscriber ){
this . subscriber = subscriber;
}
@Override
public void handleEvent ( CqEvent event ) {
【文件预览】：
rxfire-master
----gradlew.bat(2KB)
----server()
--------src()
----gradlew(5KB)
----gradle()
--------wrapper()
----.gitignore(150B)
----stream-aggregator()
--------src()
----README.md(2KB)
----settings.gradle(66B)
----build.gradle(1KB)