json-reactive

Use Json Reactive to make POJO binding reactively

Overview

Implementation of reactive json object reader over Jackson non blocking json parser.

Modules

json-nonblocking : non blocking implementation that can be wrapped with any reactive approach

json-reactor : io.projectreactor implementation

json-rx2 : rxJava2 implementation

Usage io.projectreactor

ReactorObjectReader reader = new ReactorObjectReader(new JsonFactory());

Flux<TestEntity> testEntityRed = reader.readElements(byteBuffers, objectMapper.readerFor(TestEntity.class));

Usage rxJava2

Rx2ObjectReader reader = new Rx2ObjectReader(new JsonFactory());

Flowable<TestEntity> testEntityRed = reader.readElements(byteBuffers, objectMapper.readerFor(TestEntity.class));

Maven

<repositories>
    <repository>
        <id>bintray-kptfh-feign-reactive</id>
        <name>bintray</name>
        <url>https://dl.bintray.com/kptfh/json-reactive</url>
    </repository>
</repositories>
...
<dependencies>
    ...

    <dependency>
        <groupId>io.kptfh.reactivejson</groupId>
        <artifactId>json-reactor</artifactId>
        <version>0.0.1</version>
    </dependency>

    or if you tend to use Rx2 interfaces

    <dependency>
        <groupId>io.kptfh.reactivejson</groupId>
        <artifactId>json-rx2</artifactId>
        <version>0.0.1</version>
    </dependency>
    ...
</dependencies>