 			describe("error action") {
 				sharedExamples("send errors to errors observable") {
 					it("work factory receives inputs") {
-						XCTAssertEqual(inputs.events, [
-							Recorded.next(10, "a"),
-							Recorded.next(20, "b")
-							])
+						XCTAssertEqual(inputs.events, Recorded.events([
+                            .next(10, "a"),
+                            .next(20, "b")
+                            ])
+                        )
 					}
 
 					it("elements observable receives nothing") {

					}

					it("errors observable receives generated errors") {
						XCTAssertEqual(errors.events, [
							Recorded.next(10, .notEnabled),
							Recorded.next(20, .notEnabled)
							])
					}

                    it("underlyingError observable receives zero generated errors") {

					}

					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") {
