Skip to content

Commit

Permalink
Merge pull request #598 from nats-io/linter
Browse files Browse the repository at this point in the history
[FIX] linter warnings
  • Loading branch information
aricart authored Sep 20, 2023
2 parents 7707f9c + cdc3537 commit dd2c1a7
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 12 deletions.
1 change: 0 additions & 1 deletion jetstream/jsclient.ts
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,6 @@ import {
import { delay, Timeout, timeout } from "../nats-base-client/util.ts";
import { headers } from "../nats-base-client/headers.ts";
import { Bucket } from "./kv.ts";
import { NatsConnectionImpl } from "../nats-base-client/nats.ts";
import { Feature } from "../nats-base-client/semver.ts";
import { ObjectStoreImpl } from "./objectstore.ts";
import { IdleHeartbeat } from "../nats-base-client/idleheartbeat.ts";
Expand Down
9 changes: 0 additions & 9 deletions jetstream/objectstore.ts
Original file line number Diff line number Diff line change
Expand Up @@ -196,15 +196,6 @@ function toServerObjectStoreMeta(
return v;
}

function meta(oi: ObjectInfo): ObjectStoreMeta {
return {
name: oi.name,
description: oi.description,
headers: oi.headers,
options: oi.options,
};
}

function emptyReadableStream(): ReadableStream {
return new ReadableStream({
pull(c) {
Expand Down
4 changes: 2 additions & 2 deletions jetstream/tests/jsm_test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2609,7 +2609,7 @@ Deno.test("jsm - stream consumer limits", async () => {
assertEquals(si.config.consumer_limits?.max_ack_pending, 20);
assertEquals(si.config.consumer_limits?.inactive_threshold, nanos(60_000));

let ci = await jsm.consumers.add("map", { durable_name: "map" });
const ci = await jsm.consumers.add("map", { durable_name: "map" });
assertEquals(ci.config.max_ack_pending, 20);
assertEquals(ci.config.inactive_threshold, nanos(60_000));

Expand Down Expand Up @@ -2654,7 +2654,7 @@ Deno.test("jsm - stream consumer limits override", async () => {

await assertRejects(
async () => {
const ci = await jsm.consumers.add("map", {
await jsm.consumers.add("map", {
durable_name: "map",
max_ack_pending: 100,
});
Expand Down

0 comments on commit dd2c1a7

Please sign in to comment.