             it("receives generated inputs") {
                 scheduler.start()
                 XCTAssertEqual(inputs.events, Recorded.events([
-					.next(10, "a"),
-					.next(20, "b")
+                    .next(10, "a"),
+                    .next(20, "b")
                     ])
-				)
+                )
             }
             it("emits nothing on `elements`") {
                 let elements = scheduler.createObserver(Never.self)

                            .next(20, "b")
                            ])
                        )
					}

					it("elements observable receives generated elements") {
						XCTAssertEqual(elements.events, Recorded.events([
							.next(10, "a"),
							.next(10, "b"),
							.next(10, "c"),
							.next(20, "b"),
							.next(20, "c"),
							.next(20, "d")
							])
                        )
					}

					it("errors observable receives nothing") {
						XCTAssertEqual(errors.events, [])
					}

					it("disabled until element returns") {
						XCTAssertEqual(enabled.events, Recorded.events([
							.next(0, true),
							.next(10, false),
							.next(10, true),
							.next(20, false),
							.next(20, true)
							])
                        )
					}

					it("executing until element returns") {
						XCTAssertEqual(executing.events, Recorded.events([
							.next(0, false),
							.next(10, true),
							.next(10, false),
							.next(20, true),
							.next(20, false)
							])
                        )
					}


            var executing: TestableObserver<Bool>!
            var executionObservables: TestableObserver<Observable<String>>!
            var underlyingError: TestableObserver<Error>!
            
            beforeEach {
                inputs = scheduler.createObserver(String.self)
                elements = scheduler.createObserver(String.self)
