 			next(680, 2),
 			error(690, RepeatTestErrors.fatalError)]
 		
+		// provide simple predicate that always return true
 		let res = scheduler.start(0, subscribed: 0, disposed: 1000) { () -> Observable<Int> in
 			return self.sampleValues.asObservable().retry(.Immediate(maxAttemptCount: 3), scheduler: self.scheduler) { _ in
 				return true

			next(220, 2),
			error(230, RepeatTestErrors.fatalError)]
		
		let res = scheduler.start(0, subscribed: 0, disposed: 1000) { () -> Observable<Int> in
			return self.sampleValues.asObservable().retry(.Immediate(maxAttemptCount: 3), scheduler: self.scheduler) { _ in
				return false

import RxSwiftExt
import RxTests

private enum RepeatTestErrors : ErrorType {
	case fatalError
}

