KarthicRaj

## simpleRxComposition.groovy
/**
 * Asynchronously calls 'customObservableNonBlocking' and defines
 * a chain of operators to apply to the callback sequence.
 */
def simpleComposition() {
  // fetch an asynchronous Observable<String>
  // that emits 75 Strings of 'anotherValue_#'
  customObservableNonBlocking()
    // skip the first 10
    .skip(10)
	/**
	* Asynchronously calls 'customObservableNonBlocking' and defines
	* a chain of operators to apply to the callback sequence.
	*/
	def simpleComposition() {
	// fetch an asynchronous Observable<String>
	// that emits 75 Strings of 'anotherValue_#'
	customObservableNonBlocking()
	// skip the first 10
	.skip(10)