fix: Revert "feat: support grpc-web client straming (#617)" (#632)

This reverts commit d3e7f1f.

integration/grpc-web-go-server/build.sh

@@ -1,10 +1,14 @@
 #!/usr/bin/env bash
 
 set -x
+export GOPATH=$HOME/go
 
-GO111MODULE=on go mod tidy
-
-go build
+# See https://grpc.io/docs/languages/go/quickstart/
+# go get google.golang.org/protobuf/cmd/protoc-gen-go
+# go get google.golang.org/grpc/cmd/protoc-gen-go-grpc
+#
+# go get github.com/improbable-eng/grpc-web/go/grpcweb
 
 mkdir -p generated
 protoc -I=. --go_out=generated/ --go-grpc_out=require_unimplemented_servers=false:generated/ example.proto
+

integration/grpc-web-go-server/example.proto

@@ -6,8 +6,6 @@ option go_package = "lib/rpx";
 service DashState {
   rpc UserSettings(Empty) returns (DashUserSettingsState);
   rpc ActiveUserSettingsStream(Empty) returns (stream DashUserSettingsState);
-  rpc ManyUserSettingsStream(stream DashUserSettingsState) returns (DashUserSettingsState);
-  rpc ChangeUserSettingsStream (stream DashUserSettingsState) returns (stream DashUserSettingsState) {}
 }
 
 message DashFlash {
@@ -67,4 +65,4 @@ message DashAPICredsDeleteReq {
   string id = 3;
 }
 
-message Empty {}
+message Empty {}

integration/grpc-web-go-server/example.ts

@@ -593,8 +593,6 @@ export const Empty = {
 export interface DashState {
   UserSettings(request: Empty): Promise<DashUserSettingsState>;
   ActiveUserSettingsStream(request: Empty): Observable<DashUserSettingsState>;
-  ManyUserSettingsStream(request: Observable<DashUserSettingsState>): Observable<DashUserSettingsState>;
-  ChangeUserSettingsStream(request: Observable<DashUserSettingsState>): Observable<DashUserSettingsState>;
 }
 
 export class DashStateClientImpl implements DashState {
@@ -603,8 +601,6 @@ export class DashStateClientImpl implements DashState {
     this.rpc = rpc;
     this.UserSettings = this.UserSettings.bind(this);
     this.ActiveUserSettingsStream = this.ActiveUserSettingsStream.bind(this);
-    this.ManyUserSettingsStream = this.ManyUserSettingsStream.bind(this);
-    this.ChangeUserSettingsStream = this.ChangeUserSettingsStream.bind(this);
   }
   UserSettings(request: Empty): Promise<DashUserSettingsState> {
     const data = Empty.encode(request).finish();
@@ -617,18 +613,6 @@ export class DashStateClientImpl implements DashState {
     const result = this.rpc.serverStreamingRequest('rpx.DashState', 'ActiveUserSettingsStream', data);
     return result.pipe(map((data) => DashUserSettingsState.decode(new _m0.Reader(data))));
   }
-
-  ManyUserSettingsStream(request: Observable<DashUserSettingsState>): Observable<DashUserSettingsState> {
-    const data = request.pipe(map((request) => DashUserSettingsState.encode(request).finish()));
-    const promise = this.rpc.clientStreamingRequest('rpx.DashState', 'ManyUserSettingsStream', data);
-    return promise.then((data) => DashUserSettingsState.decode(new _m0.Reader(data)));
-  }
-
-  ChangeUserSettingsStream(request: Observable<DashUserSettingsState>): Observable<DashUserSettingsState> {
-    const data = request.pipe(map((request) => DashUserSettingsState.encode(request).finish()));
-    const result = this.rpc.bidirectionalStreamingRequest('rpx.DashState', 'ChangeUserSettingsStream', data);
-    return result.pipe(map((data) => DashUserSettingsState.decode(new _m0.Reader(data))));
-  }
 }
 
 /**