文件名称：rxfire:gemfire 的响应式扩展
文件大小：64KB
文件格式：ZIP
更新时间：2024-07-03 12:37:13
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)