 			next(270, 6),
 			completed(300)
 			])
+     
+        sampleValuesImmediateError = scheduler.createColdObservable([
+            error(230, RepeatTestErrors.fatalError),
+            ])
+        
+        sampleValuesNeverError = scheduler.createColdObservable([
+            next(210, 1),
+            next(220, 2),
+            next(240, 3),
+            next(250, 4),
+            next(260, 5),
+            next(270, 6),
+            completed(300)
+            ])
 	}
 	
 	override func tearDown() {

		XCTAssertEqual(res.events, correctValues)
	}
	
	
	func testImmediateRetryWithPredicate() {
		let correctValues = [
			next(210, 1),


class RetryWithBehaviorTests: XCTestCase {
	var sampleValues: TestableObservable<Int>!
    var sampleValuesImmediateError: TestableObservable<Int>!
    var sampleValuesNeverError: TestableObservable<Int>!
	let scheduler = TestScheduler(initialClock: 0)
	
	override func setUp() {
