Skip to content

Commit

Permalink
[FIX] linter
Browse files Browse the repository at this point in the history
  • Loading branch information
aricart committed Oct 26, 2023
1 parent 17a02a6 commit 86576f9
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 22 deletions.
2 changes: 0 additions & 2 deletions jetstream/tests/consumers_next.ts
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,6 @@ import { AckPolicy, DeliverPolicy } from "../jsapi_types.ts";
import { assertEquals } from "https://deno.land/[email protected]/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/[email protected]/assert/assert_exists.ts";

Deno.test("consumers - next", async () => {
const { ns, nc } = await setup(jetstreamServerConf());
Expand Down
5 changes: 1 addition & 4 deletions jetstream/tests/consumers_test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ import {
assertRejects,
assertStringIncludes,
} from "https://deno.land/[email protected]/assert/mod.ts";
import { deferred, Empty, StringCodec } from "../../nats-base-client/mod.ts";
import { deferred } from "../../nats-base-client/mod.ts";
import {
AckPolicy,
Consumer,
Expand All @@ -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({}));
Expand Down
18 changes: 2 additions & 16 deletions jetstream/tests/jetstream_test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand All @@ -38,11 +35,9 @@ import {
} from "../../nats-base-client/internal_mod.ts";
import {
createInbox,
DebugEvents,
deferred,
Empty,
ErrorCode,
Events,
headers,
JSONCodec,
NatsError,
Expand All @@ -54,7 +49,6 @@ import {
assertArrayIncludes,
assertEquals,
assertExists,
assertIsError,
assertRejects,
assertThrows,
fail,
Expand All @@ -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) => {
Expand Down

0 comments on commit 86576f9

Please sign in to comment.