                 }
                 
                 it("element receives 3 values for each execution") {
-                    XCTAssertEqual(element.events, Recorded.events([
-                      .next(10, "a"),
-                      .next(10, "a"),
-                      .next(10, "a"),
-                      .completed(10),
-                      .next(20, "b"),
-                      .next(20, "b"),
-                      .next(20, "b"),
-                      .completed(20)
-                      ])
-                    )
+                    expect(element.events).to(match(TestEvents.multipleExecutionStreams))
                 }
                 
                 it("executes twice") {
-                    expect(executionObservables.events.count) == 2
+                    expect(executionObservables.events.count).to(match(2))
                 }
             }
             

                }
                
                it("element fails with notEnabled") {
                    XCTAssertEqual(element.events, Recorded.events([
                      .error(10, ActionError.notEnabled),
                      .error(20, ActionError.notEnabled)
                      ])
                    )
                }
                
                it("never executes") {

				}

                it("element receives single value for each execution") {
                    expect(element.events).to(match(TestEvents.executionStreams))
                }
                
                it("executes twice") {
                    expect(executionObservables.events.count).to(match(2))
                }
            }
            
