Skip to content

Commit

Permalink
Remove some dead code
Browse files Browse the repository at this point in the history
  • Loading branch information
Paul Tyng committed Oct 4, 2017
1 parent 8e1dec5 commit a23c9bd
Showing 1 changed file with 0 additions and 15 deletions.
15 changes: 0 additions & 15 deletions mem/server_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,21 +29,6 @@ func (r *ConcurrentReceiver) Receive(ctx context.Context, m *msg.Message) error
return nil
}

// PanicReceiver panics upon consumption of a message.
// It is safe to utilize by concurrent goroutines.
type PanicReceiver struct {
t *testing.T
}

func (r *PanicReceiver) Receive(ctx context.Context, m *msg.Message) error {
select {
case <-ctx.Done():
return ctx.Err()
default:
panic("AHHH")
}
}

// RetryReceiver returns an error upon consumption of a Message. Once it
// has been called a certain number of times, it writes to an channel and
// returns nil.
Expand Down

0 comments on commit a23c9bd

Please sign in to comment.