clone of scala rx