diff --git a/event/stream/reconnect_test.go b/event/stream/reconnect_test.go index fd229a5..9162768 100644 --- a/event/stream/reconnect_test.go +++ b/event/stream/reconnect_test.go @@ -44,11 +44,11 @@ func TestStream_RecreatesSubscriptionAfterRepeatedPullErrors(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() s, err := newStream(ctx, fc, Options{ - DeviceID: "cam-1", - PullTimeout: 50 * time.Millisecond, - ReconnectAfterFailures: 1, - RetryBackoff: 10 * time.Millisecond, - InitialTermination: 30 * time.Second, // keep renew quiet + DeviceID: "cam-1", + PullTimeout: 50 * time.Millisecond, + ReconnectAfterFailures: 1, + RetryBackoff: 10 * time.Millisecond, + InitialTermination: 30 * time.Second, // keep renew quiet }) require.NoError(t, err) defer s.Close()