Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
paulwe committed Mar 26, 2024
1 parent 834fc93 commit 240799f
Showing 1 changed file with 0 additions and 15 deletions.
15 changes: 0 additions & 15 deletions internal/test/my_service/my_service_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -185,21 +185,6 @@ func testGeneratedService(t *testing.T, bus func() psrpc.MessageBus) {
require.NoError(t, subB.Close())
}

func requireOne(t *testing.T, subA, subB psrpc.Subscription[*MyUpdate]) {
var n int
select {
case <-subA.Channel():
n++
case <-time.After(time.Second):
}
select {
case <-subB.Channel():
n++
case <-time.After(time.Second):
}
require.Equal(t, 1, n, "expected one response")
}

func requireTwo(t *testing.T, subA, subB psrpc.Subscription[*MyUpdate]) {
for i := 0; i < 2; i++ {
select {
Expand Down

0 comments on commit 240799f

Please sign in to comment.