 				sharedExamples("send elements to elements observable") {
 					it("work factory receives inputs") {
 						XCTAssertEqual(inputs.events, Recorded.events([
-							.next(10, "a"),
-							.next(20, "b")
-							])
-                        )
-					}
-
-					it("elements observable receives generated elements") {
-						XCTAssertEqual(elements.events, Recorded.events([
-							.next(10, "a"),
-							.next(20, "b")
-							])
-                        )
-					}
-
-					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)
-							])
+						  .next(10, "a"),
+						  .next(20, "b")
+						  ])
+                        )
+                    }
+                    
+                    it("elements observable receives generated elements") {
+                        XCTAssertEqual(elements.events, Recorded.events([
+                          .next(10, "a"),
+                          .next(20, "b")
+                          ])
+                        )
+                    }
+                    
+                    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)
+                            ])
                         )
 					}
 

                        ])
                    )
                }

				it("executes twice") {
					expect(executionObservables.events.count) == 2
				}
			}

			context("multiple element action") {
				beforeEach {
					action = Action { Observable.of($0, $0, $0) }
					bindAndExecuteTwice(action: action)
				}

                it("element receives 3 values for each execution") {
                    XCTAssertEqual(element.events, Recorded.events([
                        .next(10, "a"),

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