Monadic reactive streams