Fixed subscriber.

Author: fenying

src/examples/debug.ts

@@ -10,14 +10,19 @@ import * as L from "@litert/core";
 
     try {
 
-        await cli.connect();
         await sub.connect();
 
-        await cli.auth("hello");
         await sub.auth("hello");
 
+        sub.on("message", function(c, d, p): void {
+
+            console.log(`Channel: ${c}, Data: ${d.toString()}`);
+        });
+
         await sub.subscribe(["hello"]);
 
+        await cli.connect();
+        await cli.auth("hello");
         console.log(await cli.set("a", "123"));
         console.log(await cli.get("a"));
         console.log(await cli.mGet(["a", "sada"]));
@@ -44,6 +49,7 @@ import * as L from "@litert/core";
         await L.Async.sleep(2000);
 
         await cli.shutdown();
+        await sub.shutdown();
     }
     catch (e) {
 

src/lib/BaseClient.ts

@@ -9,11 +9,12 @@ extends ProtocolClient {
     public constructor(
         host: string,
         port: number,
-        _decoder: C.IDecoder,
-        _encoder: C.IEncoder
+        decoder: C.IDecoder,
+        encoder: C.IEncoder,
+        subscribeMode?: boolean
     ) {
 
-        super(host, port, _decoder, _encoder);
+        super(host, port, decoder, encoder, subscribeMode);
     }
 
     protected _onConnected(callback: C.ICallbackA): void {

src/lib/ModuleAPI.ts

@@ -60,4 +60,3 @@ export function createSubscriberClient(
         encoder
     );
 }
-

src/lib/Subscriber.ts

@@ -17,7 +17,7 @@ implements C.ISubscriberClient {
         _encoder: C.IEncoder
     ) {
 
-        super(host, port, _decoder, _encoder);
+        super(host, port, _decoder, _encoder, true);
     }
 
     protected _onConnected(callback: C.ICallbackA): void {