Skip to content

Commit

Permalink
Fix unit tests.
Browse files Browse the repository at this point in the history
  • Loading branch information
blakerouse committed Mar 31, 2021
1 parent d8da230 commit 7d1da80
Showing 1 changed file with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -87,14 +87,14 @@ func TestRouter(t *testing.T) {
})

assertOps(t, []event{
e(pipeline.DefaultRK, createOp),
e(pipeline.DefaultRK, executeOp),

e(k1, createOp),
e(k1, executeOp),

e(k2, createOp),
e(k2, executeOp),

e(pipeline.DefaultRK, createOp),
e(pipeline.DefaultRK, executeOp),
}, recorder.events)

recorder.reset()
Expand All @@ -108,9 +108,9 @@ func TestRouter(t *testing.T) {
e(nk, createOp),
e(nk, executeOp),

e(pipeline.DefaultRK, closeOp),
e(k1, closeOp),
e(k2, closeOp),
e(pipeline.DefaultRK, closeOp),
}, recorder.events)
})

Expand Down Expand Up @@ -152,22 +152,22 @@ func TestRouter(t *testing.T) {
})

assertOps(t, []event{
e(pipeline.DefaultRK, createOp),
e(pipeline.DefaultRK, executeOp),
e(k1, createOp),
e(k1, executeOp),
e(k2, createOp),
e(k2, executeOp),
e(pipeline.DefaultRK, createOp),
e(pipeline.DefaultRK, executeOp),
}, recorder.events)

recorder.reset()

r.Route("hello-2", map[pipeline.RoutingKey][]program.Program{})

assertOps(t, []event{
e(pipeline.DefaultRK, closeOp),
e(k1, closeOp),
e(k2, closeOp),
e(pipeline.DefaultRK, closeOp),
}, recorder.events)
})
}
Expand Down

0 comments on commit 7d1da80

Please sign in to comment.