From 86576f92c395fcd5d54bfecb8857bc36a45c8216 Mon Sep 17 00:00:00 2001 From: Alberto Ricart Date: Thu, 26 Oct 2023 09:43:06 -0500 Subject: [PATCH] [FIX] linter --- jetstream/tests/consumers_next.ts | 2 -- jetstream/tests/consumers_test.ts | 5 +---- jetstream/tests/jetstream_test.ts | 18 ++---------------- 3 files changed, 3 insertions(+), 22 deletions(-) diff --git a/jetstream/tests/consumers_next.ts b/jetstream/tests/consumers_next.ts index b741e2f4..b07f936b 100644 --- a/jetstream/tests/consumers_next.ts +++ b/jetstream/tests/consumers_next.ts @@ -23,8 +23,6 @@ import { AckPolicy, DeliverPolicy } from "../jsapi_types.ts"; import { assertEquals } from "https://deno.land/std@0.200.0/assert/assert_equals.ts"; import { nanos } from "../jsutil.ts"; import { NatsConnectionImpl } from "../../nats-base-client/nats.ts"; -import { syncIterator } from "../../nats-base-client/core.ts"; -import { assertExists } from "https://deno.land/std@0.200.0/assert/assert_exists.ts"; Deno.test("consumers - next", async () => { const { ns, nc } = await setup(jetstreamServerConf()); diff --git a/jetstream/tests/consumers_test.ts b/jetstream/tests/consumers_test.ts index c3263913..3b4b7778 100644 --- a/jetstream/tests/consumers_test.ts +++ b/jetstream/tests/consumers_test.ts @@ -19,7 +19,7 @@ import { assertRejects, assertStringIncludes, } from "https://deno.land/std@0.200.0/assert/mod.ts"; -import { deferred, Empty, StringCodec } from "../../nats-base-client/mod.ts"; +import { deferred } from "../../nats-base-client/mod.ts"; import { AckPolicy, Consumer, @@ -42,9 +42,6 @@ import { ConsumerStatus, PullConsumerMessagesImpl, } from "../consumer.ts"; -import { deadline } from "../../nats-base-client/util.ts"; -import { syncIterator } from "../../nats-base-client/core.ts"; -import { setupStreamAndConsumer } from "../../examples/jetstream/util.ts"; Deno.test("consumers - min supported server", async () => { const { ns, nc } = await setup(jetstreamServerConf({})); diff --git a/jetstream/tests/jetstream_test.ts b/jetstream/tests/jetstream_test.ts index a3361e07..9bc48724 100644 --- a/jetstream/tests/jetstream_test.ts +++ b/jetstream/tests/jetstream_test.ts @@ -14,12 +14,9 @@ */ import { NatsServer } from "../../tests/helpers/launcher.ts"; -import { initStream, time } from "./jstest_util.ts"; +import { initStream } from "./jstest_util.ts"; import { AckPolicy, - checkJsError, - ConsumerConfig, - ConsumerOpts, consumerOpts, DeliverPolicy, JsHeaders, @@ -38,11 +35,9 @@ import { } from "../../nats-base-client/internal_mod.ts"; import { createInbox, - DebugEvents, deferred, Empty, ErrorCode, - Events, headers, JSONCodec, NatsError, @@ -54,7 +49,6 @@ import { assertArrayIncludes, assertEquals, assertExists, - assertIsError, assertRejects, assertThrows, fail, @@ -69,21 +63,13 @@ import { import { defaultJsOptions } from "../jsbaseclient_api.ts"; import { connect } from "../../src/connect.ts"; import { - assertBetween, cleanup, - disabled, - jetstreamExportServerConf, jetstreamServerConf, Lock, notCompatible, setup, } from "../../tests/helpers/mod.ts"; -import { isFlowControlMsg, isHeartbeatMsg, Js409Errors } from "../jsutil.ts"; -import { - ConsumerOptsBuilderImpl, - JetStreamSubscriptionInfoable, -} from "../types.ts"; -import { syncIterator } from "../../nats-base-client/core.ts"; +import { ConsumerOptsBuilderImpl } from "../types.ts"; export function callbackConsume(debug = false): JsMsgCallback { return (err: NatsError | null, jm: JsMsg | null) => {