Cartesius is a language for programming joins over asynchronous streams uniformly and extensibly.
The source code can be found here.
Versatile Event Correlation with Algebraic Effects (ICFP 2018)
by Oliver Bračevac, Nada Amin, Guido Salvaneschi, Sebastian Erdweg, Patrick Eugster, and Mira Mezini
(pdf)