This paper presents a framework for real-time reactive stream processing. The approach is to extend the proposed Java 9 Reactive Streams model and integrate it with the Real-Time Specification for Java. The approach leverages a real-time version of the Java 8 Stream processing framework. Our approach addresses the major issue when using Reactive Streams in real-time: there is no way to set the timeout. Our evaluation shows there is significant improvement in the predictability of stream processing with our framework over that of one implemented using regular Java.

BibTex Entry

@inproceedings{HaiTaoMe2016,
 author = {HaiTao Me, Ian Gray and Andy Wellings},
 booktitle = {Proceedings of the 19th IEEE International Symposium on Real-Time Computing},
 title = {A Java-Based Real-Time Reactive Stream Framework},
 year = {2016}
}