Use Json Reactive to make POJO binding reactively
Implementation of reactive json object reader over Jackson non blocking json parser.
json-nonblocking : non blocking implementation that can be wrapped with any reactive approach
json-reactor : io.projectreactor implementation
json-rx2 : rxJava2 implementation
ReactorObjectReader reader = new ReactorObjectReader(new JsonFactory()); Flux<TestEntity> testEntityRed = reader.readElements(byteBuffers, objectMapper.readerFor(TestEntity.class));Rx2ObjectReader reader = new Rx2ObjectReader(new JsonFactory()); Flowable<TestEntity> testEntityRed = reader.readElements(byteBuffers, objectMapper.readerFor(TestEntity.class));<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>