JACoW logo

Joint Accelerator Conferences Website

The Joint Accelerator Conferences Website (JACoW) is an international collaboration that publishes the proceedings of accelerator conferences held around the world.

RIS citation export for THPHA176: Streaming Pool - Managing Long-Living Reactive Streams for Java

AU - Calia, A.
AU - Fuchsberger, K.
AU - Gabriel, M.
AU - Galilée, M.A.
AU - Garnier, J.C.
AU - Hemelsoet, G.H.
AU - Hostettler, M.
AU - Hruska, M.
AU - Jacquet, D.
AU - Makai, J.
AU - Martins Ribeiro, T.
AU - Stanisz, A.
ED - Schaa, Volker RW
TI - Streaming Pool - Managing Long-Living Reactive Streams for Java
J2 - Proc. of ICALEPCS2017, Barcelona, Spain, 8-13 October 2017
C1 - Barcelona, Spain
T2 - International Conference on Accelerator and Large Experimental Control Systems
T3 - 16
LA - english
AB - A common use case in accelerator control systems is subscribing to many properties and multiple devices and combine data from this. A new technology which got standardized during recent years in software industry are so-called reactive streams. Libraries implementing this standard provide a rich set of operators to manipulate, combine and subscribe to streams of data. However, the usual focus of such streaming libraries are applications in which those streams complete within a limited amount of time or collapse due to errors. On the other hand, in the case of a control systems we want to have those streams live for a very long time (ideally infinitely) and handle errors gracefully. In this paper we describe an approach which allows two reactive stream styles: ephemeral and long-living. This allows the developers to profit from both, the extensive features of reactive stream libraries and keeping the streams alive continuously. Further plans and ideas are also discussed.
CP - Geneva, Switzerland
SP - 1837
EP - 1841
KW - ion
KW - factory
KW - controls
KW - coupling
DA - 2018/01
PY - 2018
SN - 978-3-95450-193-9
DO - 10.18429/JACoW-ICALEPCS2017-THPHA176
UR - http://jacow.org/icalepcs2017/papers/thpha176.pdf
ER -