Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
keroxp authored Jan 25, 2020
1 parent 2f8afea commit 54367b0
Show file tree
Hide file tree
Showing 10 changed files with 21 additions and 15 deletions.
2 changes: 1 addition & 1 deletion .denov
Original file line number Diff line number Diff line change
@@ -1 +1 @@
v0.29.0
v0.31.0
2 changes: 1 addition & 1 deletion modules-lock.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"https://deno.land/std": {
"version": "@v0.29.0",
"version": "@v0.31.0",
"modules": [
"/util/async.ts",
"/testing/mod.ts",
Expand Down
2 changes: 1 addition & 1 deletion modules.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"https://deno.land/std": {
"version": "@v0.29.0",
"version": "@v0.31.0",
"modules": [
"/util/async.ts",
"/testing/mod.ts",
Expand Down
12 changes: 10 additions & 2 deletions pipeline_test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -91,11 +91,19 @@ test("pipeline in concurrent", async () => {
"OK", //set(a)
"OK", //set(b)
"OK", //set(c)
[["status", "OK"], ["status", "OK"], ["status", "OK"]], //flush()
[
["status", "OK"],
["status", "OK"],
["status", "OK"]
], //flush()
"OK", // get(a)
"OK", // get(b)
"OK", //get(c)
[["bulk", "a"], ["bulk", "b"], ["bulk", "c"]] //flush()
[
["bulk", "a"],
["bulk", "b"],
["bulk", "c"]
] //flush()
]);
});

Expand Down
8 changes: 3 additions & 5 deletions redis.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,3 @@
import DialOptions = Deno.DialOptions;

type Reader = Deno.Reader;
type Writer = Deno.Writer;
type Closer = Deno.Closer;
Expand Down Expand Up @@ -1576,16 +1574,16 @@ export async function connect({
tls,
db
}: RedisConnectOptions): Promise<Redis> {
const dialOpts: DialOptions = {
const dialOpts: Deno.ConnectOptions = {
hostname,
port: prasePortLike(port)
};
if (!Number.isSafeInteger(dialOpts.port)) {
throw new Error("deno-redis: opts.port is invalid");
}
const conn: Deno.Conn = tls
? await Deno.dialTLS(dialOpts)
: await Deno.dial(dialOpts);
? await Deno.connectTLS(dialOpts)
: await Deno.connect(dialOpts);
const client = await create(conn, conn, conn);
if (db) {
await client.select(db);
Expand Down
2 changes: 1 addition & 1 deletion vendor/https/deno.land/std/fmt/colors.ts
Original file line number Diff line number Diff line change
@@ -1 +1 @@
export * from "https://deno.land/std@v0.29.0/fmt/colors.ts";
export * from "https://deno.land/std@v0.31.0/fmt/colors.ts";
2 changes: 1 addition & 1 deletion vendor/https/deno.land/std/io/bufio.ts
Original file line number Diff line number Diff line change
@@ -1 +1 @@
export * from "https://deno.land/std@v0.29.0/io/bufio.ts";
export * from "https://deno.land/std@v0.31.0/io/bufio.ts";
2 changes: 1 addition & 1 deletion vendor/https/deno.land/std/testing/asserts.ts
Original file line number Diff line number Diff line change
@@ -1 +1 @@
export * from "https://deno.land/std@v0.29.0/testing/asserts.ts";
export * from "https://deno.land/std@v0.31.0/testing/asserts.ts";
2 changes: 1 addition & 1 deletion vendor/https/deno.land/std/testing/mod.ts
Original file line number Diff line number Diff line change
@@ -1 +1 @@
export * from "https://deno.land/std@v0.29.0/testing/mod.ts";
export * from "https://deno.land/std@v0.31.0/testing/mod.ts";
2 changes: 1 addition & 1 deletion vendor/https/deno.land/std/util/async.ts
Original file line number Diff line number Diff line change
@@ -1 +1 @@
export * from "https://deno.land/std@v0.29.0/util/async.ts";
export * from "https://deno.land/std@v0.31.0/util/async.ts";

0 comments on commit 54367b0

Please sign in to comment.