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

...
<dependencies>
    ...

    <dependency>
        <groupId>com.playtika.reactivejson</groupId>
        <artifactId>json-reactor</artifactId>
        <version>PICK LATEST</version>
    </dependency>

    or if you tend to use Rx2 interfaces

    <dependency>
        <groupId>com.playtika.reactivejson</groupId>
        <artifactId>json-rx2</artifactId>
        <version>PICK LATEST</version>
    </dependency>
    ...
</dependencies>