run bin2ts

stephenh · Feb 2, 2024 · dbc1266 · dbc1266
1 parent d86f41d
commit dbc1266
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/integration/before-after-request-streaming/example.ts b/integration/before-after-request-streaming/example.ts
@@ -791,10 +791,11 @@ export class DashStateClientImpl implements DashState {
 
   ChangeUserSettingsStream(request: Observable<DashUserSettingsState>): Observable<DashUserSettingsState> {
     const data = request.pipe(map((request) => {
-      DashUserSettingsState.encode(request).finish();
+      const encodedRequest = DashUserSettingsState.encode(request).finish();
       if (this.rpc.beforeRequest) {
-        this.rpc.beforeRequest(this.service, "ChangeUserSettingsStream", request);
+        this.rpc.beforeRequest(this.service, "ChangeUserSettingsStream", encodedRequest);
       }
+      return encodedRequest;
     }));
     const result = this.rpc.bidirectionalStreamingRequest(this.service, "ChangeUserSettingsStream", data);
     return result.pipe(map((data) => {