rxnetty

library0.5.1javamavenunverified

RxNetty is a reactive extension for Netty, providing RxJava bindings for asynchronous network programming.

<dependency>
  <groupId>io.reactivex</groupId>
  <artifactId>rxnetty</artifactId>
  <version>0.5.1</version>
</dependency>

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · RXNETTY

rxnetty

networkingjavav0.5.1

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

HttpServer

✓ io.reactivex.netty.protocol.http.server.HttpServer

Minimal HTTP server using RxNetty.

import io.reactivex.netty.protocol.http.server.HttpServer; import rx.Observable; public class RxNettyExample { public static void main(String[] args) { HttpServer.newServer(8080) .start((req, resp) -> { resp.writeString(Observable.just("Hello World")); return Observable.empty(); }) .awaitShutdown(); } }

Debug

Known issues

breakingRxNetty 0.5.x is based on RxJava 1.x; newer versions use RxJava 2+.

fix

Use io.reactivex:rxnetty-http:0.5.1 for RxJava 1 compatibility.

affects: 0.5.x

Upgrade

Version history

0.5.1latest on Maven

Audit

Dependencies

No dependency data recorded yet.

Agent activity

12 hits · last 30 days

node

OpenAI (training)

Resources

githubhttps://github.com/ReactiveX/RxNetty ↗

homepagehttps://github.com/ReactiveX/RxNetty ↗

docshttps://appdoc.app/artifact/io.reactivex/rxnetty/ ↗