From a52603ff155e994ffe7f6ddebc7a59d22af1a7a7 Mon Sep 17 00:00:00 2001 From: Bryan White Date: Tue, 24 Oct 2023 15:06:29 +0200 Subject: [PATCH] test: reorder to improve readibility --- pkg/observable/channel/replay_test.go | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/pkg/observable/channel/replay_test.go b/pkg/observable/channel/replay_test.go index 4d595e4cf..4a2652c23 100644 --- a/pkg/observable/channel/replay_test.go +++ b/pkg/observable/channel/replay_test.go @@ -10,12 +10,12 @@ import ( ) func TestReplayObservable(t *testing.T) { - ctx, cancel := context.WithCancel(context.Background()) + var ( + n, values = 3, []int{1, 2, 3, 4, 5} + ctx, cancel = context.WithCancel(context.Background()) + ) t.Cleanup(cancel) - n := 3 - values := []int{1, 2, 3, 4, 5} - obsvbl, publishCh := channel.NewObservable[int]() replayObsvbl := channel.Replay[int](ctx, n, obsvbl) @@ -71,13 +71,11 @@ func TestReplayObservable(t *testing.T) { } func TestReplayObservable_Next(t *testing.T) { - ctx := context.Background() - n := 3 - values := []int{1, 2, 3, 4, 5} + var n, ctx = 3, context.Background() - obsvbl, publishCh := channel.NewObservable[int]() - replayObsvbl := channel.Replay[int](ctx, n, obsvbl) + replayObsvbl, publishCh := channel.NewReplayObservable[int](ctx, n) + values := []int{1, 2, 3, 4, 5} for _, value := range values { publishCh <- value time.Sleep(time.Millisecond)