An Rx based map implementation