Skip to content

Commit

Permalink
deno 1.29.2 formatting changes
Browse files Browse the repository at this point in the history
  • Loading branch information
aricart committed Jan 12, 2023
1 parent a0ffce0 commit 6527682
Show file tree
Hide file tree
Showing 10 changed files with 40 additions and 45 deletions.
2 changes: 1 addition & 1 deletion doc/snippets/wildcard_subscriptions.ts
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ const s3 = nc.subscribe("help.>");
async function printMsgs(s: Subscription) {
const subj = s.getSubject();
console.log(`listening for ${subj}`);
const c = (13 - subj.length);
const c = 13 - subj.length;
const pad = "".padEnd(c);
for await (const m of s) {
console.log(
Expand Down
18 changes: 9 additions & 9 deletions nats-base-client/jsclient.ts
Original file line number Diff line number Diff line change
Expand Up @@ -232,14 +232,14 @@ export class JetStreamClientImpl extends BaseApiClient
}

/*
* Returns available messages upto specified batch count.
* If expires is set the iterator will wait for the specified
* amount of millis before closing the subscription.
* If no_wait is specified, the iterator will return no messages.
* @param stream
* @param durable
* @param opts
*/
* Returns available messages upto specified batch count.
* If expires is set the iterator will wait for the specified
* amount of millis before closing the subscription.
* If no_wait is specified, the iterator will return no messages.
* @param stream
* @param durable
* @param opts
*/
fetch(
stream: string,
durable: string,
Expand Down Expand Up @@ -900,7 +900,7 @@ class JetStreamPullSubscriptionImpl extends JetStreamSubscriptionImpl
}
}

const api = (this.info.api as BaseApiClient);
const api = this.info.api as BaseApiClient;
const subj = `${api.prefix}.CONSUMER.MSG.NEXT.${stream}.${consumer}`;
const reply = this.sub.subject;

Expand Down
26 changes: 13 additions & 13 deletions nats-base-client/nuid.ts
Original file line number Diff line number Diff line change
@@ -1,17 +1,17 @@
/*
* Copyright 2016-2021 The NATS Authors
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
* Copyright 2016-2021 The NATS Authors
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/

"use strict";

Expand Down
26 changes: 13 additions & 13 deletions nats-base-client/options.ts
Original file line number Diff line number Diff line change
@@ -1,17 +1,17 @@
/*
* Copyright 2021 The NATS Authors
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
* Copyright 2021 The NATS Authors
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/

import { extend } from "./util.ts";
import { ErrorCode, NatsError } from "./error.ts";
Expand Down
1 change: 0 additions & 1 deletion nats-base-client/servers.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
import {
DEFAULT_HOST,
Expand Down
8 changes: 4 additions & 4 deletions tests/autounsub_test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -93,11 +93,11 @@ Deno.test("autounsub - request receives expected count with multiple helpers", a
const { ns, nc } = await setup();
const subj = createInbox();

const fn = (async (sub: Subscription) => {
const fn = async (sub: Subscription) => {
for await (const m of sub) {
m.respond();
}
});
};
const subs: Subscription[] = [];
for (let i = 0; i < 5; i++) {
const sub = nc.subscribe(subj);
Expand All @@ -121,12 +121,12 @@ Deno.test("autounsub - manual request receives expected count with multiple help
const subj = createInbox();
const lock = Lock(5);

const fn = (async (sub: Subscription) => {
const fn = async (sub: Subscription) => {
for await (const m of sub) {
m.respond();
lock.unlock();
}
});
};
for (let i = 0; i < 5; i++) {
const sub = nc.subscribe(subj);
fn(sub).then();
Expand Down
1 change: 0 additions & 1 deletion tests/drain_test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
import {
assert,
Expand Down
1 change: 0 additions & 1 deletion tests/reconnect_test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
import {
assert,
Expand Down
1 change: 0 additions & 1 deletion tests/servers_test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
import { isIPV4OrHostname, Servers } from "../nats-base-client/servers.ts";
import { assertEquals } from "https://deno.land/std@0.171.0/testing/asserts.ts";
Expand Down
1 change: 0 additions & 1 deletion tests/timeout_test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
import {
assertStringIncludes,
Expand Down

0 comments on commit 6527682

Please sign in to comment.