Initial implementation of RxScala Observable interface for result sets and queries.