Skip to content

Commit 7b910ae

Browse files
authored
Fix Integration Tests (#1523)
* fix tests
1 parent 6bef50b commit 7b910ae

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

internal/file/file_service_operator.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -542,6 +542,7 @@ func (fso *FileServiceOperator) sendFileUpdateStreamChunks(
542542
// Ensure the stream is closed and wait for the server's response only
543543
// after all chunks are sent
544544
_, err = updateFileStreamClient.CloseAndRecv()
545+
545546
return err
546547
}
547548

test/mock/grpc/mock_management_file_service.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -217,6 +217,8 @@ func (mgs *FileService) UpdateFileStream(streamingServer grpc.ClientStreamingSer
217217
return writeChunkedFileError
218218
}
219219

220+
streamingServer.SendAndClose(&v1.UpdateFileResponse{})
221+
220222
return nil
221223
}
222224

0 commit comments

Comments
 (0)