RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
-
Updated
Nov 10, 2021 - Java
{{ message }}
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
hsweb (haʊs wɛb) 是一个基于spring-boot 2.x开发 ,首个使用全响应式编程的企业级后台管理系统基础项目。
Automatic binding+disposal of RxJava streams.
Streams of values over time
JetLinks 基于Java8,Spring Boot 2.x ,WebFlux,Netty,Vert.x,Reactor等开发, 是一个全响应式的企业级物联网平台。支持统一物模型管理,多种设备,多种厂家,统一管理。统一设备连接管理,多协议适配(TCP,MQTT,UDP,CoAP,HTTP等),屏蔽网络编程复杂性,灵活接入不同厂家不同协议等设备。实时数据处理,设备告警,消息通知,数据转发。地理位置,数据可视化等。能帮助你快速建立物联网相关业务系统。
Asynchronous, Reactive Programming for Scala and Scala.js.
reactor-pool supports metrics beyond those which reactor-netty understands: #getMaxAllocatedSize() and #getMaxPendingAcquireSize(). It would be great if these could be made available to [reactor-netty's ConnectionPoolMetrics](https://github.com/reactor/reactor-netty/blob/main/reactor-netty-co
Elasticsearch Scala Client - Reactive, Non Blocking, Type Safe, HTTP Client
Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
An advanced, but easy to use, platform for writing functional applications in Java 8.
Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
The Scala HTTP client you always wanted!
Schema safe, type-safe, reactive Scala driver for Cassandra/Datastax Enterprise
Spring 5 Reactive playground
CombineExt provides a collection of operators, publishers and utilities for Combine, that are not provided by Apple themselves, but are common in other Reactive Frameworks and standards.
Library to convert between RxJava 1.x and 2.x/3.x reactive types, schedulers and resource handles.
Bi-directional type bridging between RxSwift and Apple's Combine framework
Postgresql R2DBC Driver
BufferInputStream does not implement mark/reset methods of the InputStream, while we can. We should implement it to make it close to ByteArrayInputStream and ByteBufInputStream (from netty) behavior.
RxJava 2.x & 3.x extra sources, operators and components and ports of many 1.x companion libraries.
a microservices library - scalecube-services is a high throughput, low latency reactive microservices library built to scale. it features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing. its open and designed to accommodate changes. (no sidecar in a form of broker or any kind)
The client is currently only logging errors and warnings. For debugging purposes and during application development, it would be very useful to also have logs detailing the message flow.
TRACE level logging for incoming and outgoing MQTT control packet types, e.g., PUBLISH, SUBSCRIBE, PUBACK, SUBACK.
R2DBC MySQL Implementation
Simple, expressive, and safe UI library for Scala.js
JetLinks Core
We make sure in the CI configuration to build with jdk8, but it would be safer to specify this in the build (javacOptions/scalacOptions) explicitly.
Testing tools and utilities for Apple's Combine framework.
RxJava2 integration with JDBC including Non-blocking Connection Pools
Add a description, image, and links to the reactive-streams topic page so that developers can more easily learn about it.
To associate your repository with the reactive-streams topic, visit your repo's landing page and select "manage topics."
Currently the reference guide #content div has
max-width: 62.5emset.This is a bit on the low end for large screens in landscape mode, and could instead be set to eg.
60%.Beyond that the rendering is starting to feel too large for paragraphs, but at 60% most large codeblocks read far better.
For phones, detecting portrait orientation and setting the
max-widthto100%would also be a