Skip to content

Commit

Permalink
Refactor cchunk to TimestampedChunk
Browse files Browse the repository at this point in the history
Refactor cchunk to TimestampedChunk
  • Loading branch information
stv0g committed Nov 16, 2022
1 parent 8c5d1fd commit ca9a267
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions vnet/delay_filter_test.go
Expand Up @@ -17,14 +17,14 @@ func TestDelayFilter(t *testing.T) {
defer cancel()
go df.Run(ctx)

type cchunk struct {
type TimestampedChunk struct {
ts time.Time
c Chunk
}
receiveCh := make(chan cchunk)
receiveCh := make(chan TimestampedChunk)
nic.mockOnInboundChunk = func(c Chunk) {
receivedAt := time.Now()
receiveCh <- cchunk{
receiveCh <- TimestampedChunk{
ts: receivedAt,
c: c,
}
Expand Down Expand Up @@ -60,14 +60,14 @@ func TestDelayFilter(t *testing.T) {
defer cancel()
go df.Run(ctx)

type cchunk struct {
type TimestampedChunk struct {
ts time.Time
c Chunk
}
receiveCh := make(chan cchunk)
receiveCh := make(chan TimestampedChunk)
nic.mockOnInboundChunk = func(c Chunk) {
receivedAt := time.Now()
receiveCh <- cchunk{
receiveCh <- TimestampedChunk{
ts: receivedAt,
c: c,
}
Expand Down

0 comments on commit ca9a267

Please sign in to comment.