search

reactive-ipc / reactive-ipc-jvm

Reactive IPC for the JVM
Apache License 2.0
55 stars 13 forks source link

Add Netty codec samples, unit tests, and improve build JDK version settings #32

Closed rstoyanchev closed 9 years ago

rstoyanchev commented 9 years ago

This PR adds sample code with Netty codecs to help with #28.

One example uses Netty's LineBasedFrameDecoder to split the input stream into messages based on new line characters. Another example uses Netty's JsonObjectDecoder to split the input stream by matching curly braces + a simple Jakson-based custom decoder for actually decoding the JSON.

Both examples request one 1 item at a time and also allow configuring Netty's input buffer size to experiment with the effect of calls to channel.read. A separate PR will be sent short with example read backpressure support for discussion and comments will be added under #28.

The PR also includes a couple more minor changes:

sdeleuze commented 9 years ago

This PR now also contains the unit tests commit