Added reactive extension support for sampling and recieved data