Achieved pipeline client.

Author: fenying

src/lib/BaseClient.ts

@@ -4,7 +4,7 @@ import { ProtocolClient } from "./ProtocolClient";
 export abstract class BaseClient
 extends ProtocolClient {
 
-    private _password!: string;
+    protected _password!: string;
 
     public constructor(
         host: string,

src/lib/RedisClient.ts renamed to src/lib/CommandClient.ts

@@ -2,8 +2,9 @@
 import * as C from "./Common";
 import * as U from "./Utils";
 import { BaseClient } from "./BaseClient";
+import { PipelineClient } from "./PipelineClient";
 
-export class RedisCommandClient
+export class CommandClient
 extends BaseClient
 implements C.ICommandClient {
 
@@ -818,4 +819,16 @@ implements C.ICommandClient {
 
         return this.command("PUBSUB", ["NUMPAT"]);
     }
+
+    public async pipeline(): Promise<C.IPipelineClient> {
+
+        const cli = new PipelineClient(this.host, this.port, this._decoder, this._encoder);
+
+        if (this._password) {
+
+            await cli.auth(this._password);
+        }
+
+        return cli;
+    }
 }

src/lib/Commands.ts

@@ -13,7 +13,7 @@ export type TProcessor = null | ((data: any, args: any[]) => any);
 
 export interface ICommand {
 
-    prepare?(...args: any[]): IPrepareResult;
+    prepare(...args: any[]): IPrepareResult;
 
     process?: TProcessor;
 }

src/lib/Common.ts

@@ -900,7 +900,13 @@ export interface ICommandAPIs {
     pubSubNumPat(): Promise<number>;
 }
 
-export interface ICommandClient extends IProtocolClient, ICommandAPIs {}
+export interface ICommandClient extends IProtocolClient, ICommandAPIs {
+
+    /**
+     * Create a client for multi-exec transaction.
+     */
+    pipeline(): Promise<IPipelineClient>;
+}
 
 export type IPipelineCommandAPIs = {
 

src/lib/ModuleAPI.ts

@@ -1,7 +1,7 @@
 import { Decoder } from "./Decoder";
 import { Encoder } from "./Encoder";
 import { ProtocolClient } from "./ProtocolClient";
-import { RedisCommandClient } from "./RedisClient";
+import { CommandClient } from "./CommandClient";
 import { SubscriberClient } from "./Subscriber";
 import * as C from "./Common";
 import { DEFUALT_PORT } from "./Constants";
@@ -23,7 +23,7 @@ export function createCommandClient(
     encoder: C.IEncoder = createEncoder()
 ): C.ICommandClient {
 
-    return new RedisCommandClient(
+    return new CommandClient(
         host,
         port,
         decoder,