client: remove servermode

Author: tsubakiky

examples/cmd/examples-go/client/main.go

@@ -16,13 +16,6 @@ import (
 	"golang.org/x/net/http2"
 )
 
-type mode int
-
-const (
-	modeClient mode = iota + 1
-	// for future use?
-	modeServer
-)
 
 type rpc int
 
@@ -34,37 +27,18 @@ const (
 )
 
 var (
-	runMode mode
 	rpcType rpc
 )
 
 func init() {
-	// mode
-	clientMode := flag.Bool("c", false, "run client mode")
-	serverMode := flag.Bool("s", false, "run server mode")
 	// rpc
 	unaryRPC := flag.Bool("u", false, "send unary RPC")
-	serverStreamingRPC := flag.Bool("ss", false, "send unary RPC")
-	clientStreamingRPC := flag.Bool("cs", false, "send unary RPC")
-	bidiRPC := flag.Bool("bidi", false, "send unary RPC")
+	serverStreamingRPC := flag.Bool("ss", false, "send server streaming RPC")
+	clientStreamingRPC := flag.Bool("cs", false, "send client streaming RPC")
+	bidiRPC := flag.Bool("bidi", false, "send bidirectional streaming RPC")
 
 	flag.Parse()
 
-	switch {
-	case *clientMode:
-		runMode = modeClient
-	case *serverMode:
-		runMode = modeServer
-	default: // throw
-		if !*clientMode && !*serverMode {
-			log.Fatal("either clientMode or serverMode must be enabled. [-c, -s]")
-		}
-		if *clientMode && *serverMode {
-			log.Fatal("neither clientMode nor serverMode can't be enabled")
-		}
-		panic("unreachable")
-	}
-
 	switch {
 	case *unaryRPC:
 		rpcType = unary
@@ -86,13 +60,8 @@ func asError(err error) (*connect.Error, bool) {
 }
 
 func main() {
-	switch runMode {
-	case modeClient:
-		if err := runClient(); err != nil {
-			log.Fatal(err)
-		}
-	case modeServer:
-		// TODO(tsubakiky): not implemented yet
+	if err := runClient(); err != nil {
+		log.Fatal(err)
 	}
 }
 

examples/proto/connectrpc/eliza/v1/v1connect/eliza_connect_pb2.py

@@ -10,7 +10,7 @@
 from connect.client import Client
 from connect.connect import StreamRequest, StreamResponse, UnaryRequest, UnaryResponse
 from connect.connection_pool import AsyncConnectionPool
-from connect.handler import ClientStreamHandler, Handler, ServerStreamHandler, UnaryHandler
+from connect.handler import ClientStreamHandler, Handler, ServerStreamHandler, UnaryHandler, BidiStreamHandler
 from connect.handler_context import HandlerContext
 from connect.options import ClientOptions, ConnectOptions
 from google.protobuf.descriptor import MethodDescriptor, ServiceDescriptor
@@ -57,7 +57,7 @@ def __init__(self, base_url: str, pool: AsyncConnectionPool, options: ClientOpti
         ).call_server_stream
         self.Introduce = Client[IntroduceRequest, IntroduceResponse](
             pool, base_url + ElizaServiceProcedures.Introduce.value, IntroduceRequest, IntroduceResponse, options
-        ).call_server_stream
+        ).call_bidi_stream
         self.Reflect = Client[ReflectRequest, ReflectResponse](
             pool, base_url + ElizaServiceProcedures.Reflect.value, ReflectRequest, ReflectResponse, options
         ).call_client_stream
@@ -94,7 +94,7 @@ def create_ElizaService_handlers(service: ElizaServiceHandler, options: ConnectO
             output=SayResponse,
             options=options,
         ),
-        ServerStreamHandler(
+        BidiStreamHandler(
             procedure=ElizaServiceProcedures.Converse.value,
             stream=service.Converse,
             input=ConverseRequest,