Rx implementation of splunk functionality