stripped out RXJava, using xtend-stream instead