fix kataras#1665

Author: kataras

_examples/README.md

@@ -251,6 +251,7 @@
     * [Websocket Controller](mvc/websocket)
     * [Register Middleware](mvc/middleware)
     * [gRPC](mvc/grpc-compatible)
+    * [gRPC Bidirectional Stream](mvc/grpc-compatible-bidirectional-stream)
     * [Login (Repository and Service layers)](mvc/login)
     * [Login (Single Responsibility)](mvc/login-mvc-single-responsibility)
     * [Vue.js Todo App](mvc/vuejs-todo-mvc)

_examples/mvc/grpc-compatible-bidirectional-stream/client/main.go

@@ -0,0 +1,49 @@
+package main
+
+import (
+	"context"
+	"time"
+
+	pb "grpcexample/helloworld"
+
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/credentials"
+)
+
+func main() {
+	// Set up a connection to the server.
+	cred, err := credentials.NewClientTLSFromFile("../server.crt", "localhost")
+	if err != nil {
+		panic(err)
+	}
+
+	conn, err := grpc.Dial("localhost:443", grpc.WithTransportCredentials(cred), grpc.WithBlock())
+	defer conn.Close()
+
+	client := pb.NewGreeterBidirectionalStreamClient(conn)
+	stream, err := client.SayHello(context.Background())
+	if err != nil {
+		panic(err)
+	}
+
+	waitCh := make(chan struct{})
+
+	// Implement the send channel.
+	// As an exercise you can implement the read channel one (reading from server, see the server/main.go).
+	go func() {
+		for {
+			println("Sleeping for 2 seconds...")
+			time.Sleep(2 * time.Second)
+			println("Sending a <test> msg...")
+			msg := &pb.HelloRequest{Name: "test"}
+
+			err = stream.Send(msg)
+			if err != nil {
+				panic("stream.Send: " + err.Error())
+			}
+		}
+	}()
+
+	<-waitCh
+	stream.CloseSend()
+}

_examples/mvc/grpc-compatible-bidirectional-stream/go.mod

@@ -0,0 +1,12 @@
+module grpcexample
+
+go 1.15
+
+// replace github.com/kataras/iris/v12 => ../../../
+
+require (
+	github.com/golang/protobuf v1.4.2
+	github.com/kataras/iris/v12 master
+	google.golang.org/grpc v1.33.1
+	google.golang.org/protobuf v1.25.0
+)

_examples/mvc/grpc-compatible-bidirectional-stream/helloworld.proto

@@ -0,0 +1,39 @@
+syntax = "proto3";
+
+package helloworld;
+
+option go_package = ".;helloworld";
+
+// The request message containing the user's name.
+message HelloRequest {
+  string name = 1;
+}
+
+// The response message containing the greetings
+message HelloReply {
+  string message = 1;
+}
+
+// The greeting service definition.
+service Greeter {
+  // Sends a greeting
+  rpc SayHello (HelloRequest) returns (HelloReply) {}
+}
+
+// The greeting service definition. (Server-side streaming RPC)
+service GreeterServerSideSStream {
+  // Sends a greeting
+  rpc SayHello (HelloRequest) returns (stream HelloReply) {}
+}
+
+// The greeting service definition. (Client-side streaming RPC)
+service GreeterClientSideStream {
+  // Sends a greeting
+  rpc SayHello (stream HelloRequest) returns (HelloReply) {}
+}
+
+// The greeting service definition. (Bidirectional streaming RPC)
+service GreeterBidirectionalStream {
+  // Sends a greeting
+  rpc SayHello (stream HelloRequest) returns (stream HelloReply) {}
+}