update readme

Author: prohazko2

README.md

@@ -13,7 +13,7 @@
 - [x] `client` unary calls
 - [x] multiplex calls
 - [x] `server` server streams
-- [ ] `client` server streams
+- [x] `client` server streams
 - [ ] context deadlines
 - [ ] logging interface
 
@@ -36,6 +36,7 @@ package prohazko;
 
 service Greeter {
   rpc SayHello (HelloRequest) returns (HelloReply) {}
+  rpc ShoutHello (HelloRequest) returns (stream HelloReply) {}
 }
 
 message HelloRequest {
@@ -52,12 +53,13 @@ message HelloReply {
 Service typings are not essential, but it's nice to have them
 
 ```sh
-$ deno run --allow-read https://deno.land/x/grpc_basic@0.3.3/gen/dts.ts ./greeter.proto > ./greeter.d.ts
+$ deno run --allow-read https://deno.land/x/grpc_basic@0.4.1/gen/dts.ts ./greeter.proto > ./greeter.d.ts
 ```
 
 ```ts
 export interface Greeter {
   SayHello(request: HelloRequest): Promise<HelloReply>;
+  ShoutHello(request: HelloRequest): AsyncGenerator<HelloReply>;
 }
 
 export interface HelloRequest {
@@ -72,38 +74,60 @@ export interface HelloReply {
 ### `server.ts`
 
 ```ts
-import { GrpcServer } from "https://deno.land/x/grpc_basic@0.3.3/server.ts";
+import { GrpcServer } from "https://deno.land/x/grpc_basic@0.4.1/server.ts";
 import { Greeter } from "./greeter.d.ts";
 
 const port = 15070;
-const root = await Deno.readTextFile("./greeter.proto");
-
 const server = new GrpcServer();
 
-server.addService<Greeter>(root, {
+const protoPath = new URL("./greeter.proto", import.meta.url);
+const protoFile = await Deno.readTextFile(protoPath);
+
+server.addService<Greeter>(protoFile, {
+  
   async SayHello({ name }) {
     const message = `hello ${name || "stranger"}`;
     return { message };
+  },
+
+  async *ShoutHello({ name }) {
+    for (const n of [0, 1, 2]) {
+      const message = `hello ${name || "stranger"} #${n}`;
+      yield { message };
+    }
   }
 });
 
 console.log(`gonna listen on ${port} port`);
 for await (const conn of Deno.listen({ port })) {
   server.handle(conn);
 }
+
 ```
 
 ### `client.ts`
 
 ```ts
-import { getClient } from "https://deno.land/x/grpc_basic@0.3.3/client.ts";
+import { getClient } from "https://deno.land/x/grpc_basic@0.4.1/client.ts";
 import { Greeter } from "./greeter.d.ts";
 
-const port = 15070;
-const root = await Deno.readTextFile("./greeter.proto");
+const protoPath = new URL("./greeter.proto", import.meta.url);
+const protoFile = await Deno.readTextFile(protoPath);
 
-const client = getClient<Greeter>({ port, root, serviceName: "Greeter" });
+const client = getClient<Greeter>({
+  port: 15070,
+  root: protoFile,
+  serviceName: "Greeter",
+});
+
+/* unary calls */
+console.log(await client.SayHello({ name: "unary #1" }));
+console.log(await client.SayHello({ name: "unary #2" }));
+
+/* server stream */
+for await (const reply of client.ShoutHello({ name: "streamed" })) {
+  console.log(reply);
+}
 
-const resp = await client.SayHello({ name: "oleg" });
-console.log(resp);
+client.close();
 ```

examples/client.ts

@@ -14,6 +14,7 @@ const client = getClient<Greeter>({
 console.log(await client.SayHello({ name: "unary #1" }));
 console.log(await client.SayHello({ name: "unary #2" }));
 
+/* server stream */
 for await (const reply of client.ShoutHello({ name: "streamed" })) {
   console.log(reply);
 }

server.ts

@@ -180,12 +180,12 @@ export class GrpcServer {
   }
 
   async handle(_conn: Deno.Conn) {
-    console.log("got new connection");
+    //console.log("got new connection");
 
     const conn = new Http2Conn(_conn);
 
     conn.c.on("stream", async (stream: Stream) => {
-      console.log("got stream", stream.id);
+      //console.log("got stream", stream.id);
 
       const [headers, dataFrame] = await Promise.all([
         waitFor<Record<string, string>>(stream, "headers"),