feat: Add new sample for response streaming

functions/responsestreaming/ResponseStreaming.sln

@@ -0,0 +1,28 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.0.31903.59
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "StreamBigQuery", "StreamBigQuery\StreamBigQuery.csproj", "{3B0C08AE-367D-4F0F-8B1D-C74093C760F8}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "StreamBigQuery.Tests", "StreamBigQuery.Tests\StreamBigQuery.Tests.csproj", "{6774A3EE-4121-4DD9-9ABD-EFB675CD6E03}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{3B0C08AE-367D-4F0F-8B1D-C74093C760F8}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{3B0C08AE-367D-4F0F-8B1D-C74093C760F8}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{3B0C08AE-367D-4F0F-8B1D-C74093C760F8}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{3B0C08AE-367D-4F0F-8B1D-C74093C760F8}.Release|Any CPU.Build.0 = Release|Any CPU
+		{6774A3EE-4121-4DD9-9ABD-EFB675CD6E03}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{6774A3EE-4121-4DD9-9ABD-EFB675CD6E03}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{6774A3EE-4121-4DD9-9ABD-EFB675CD6E03}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{6774A3EE-4121-4DD9-9ABD-EFB675CD6E03}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+EndGlobal

functions/responsestreaming/StreamBigQuery.Tests/StreamBigQuery.Tests.csproj

@@ -0,0 +1,20 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net7.0</TargetFramework>
+    <IsPackable>false</IsPackable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="JUnitTestLogger" Version="1.1.0" />
+    <PackageReference Include="Google.Cloud.Functions.Testing" Version="2.1.0" />
+    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.6.3" />
+    <PackageReference Include="xunit" Version="2.4.2" />
+    <PackageReference Include="xunit.runner.visualstudio" Version="2.4.5" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\StreamBigQuery\StreamBigQuery.csproj" />
+  </ItemGroup>
+
+</Project>

functions/responsestreaming/StreamBigQuery.Tests/StreamBigQueryTest.cs

@@ -0,0 +1,31 @@
+/*
+ * Copyright (c) 2023 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+using Google.Cloud.Functions.Testing;
+using System.Threading.Tasks;
+using Xunit;
+
+namespace StreamBigQuery.Tests;
+
+public class StreamBigQueryTest : FunctionTestBase<StreamBigQuery.Function>
+{
+    [Fact]
+    public async Task TestRunStreamBigQuery()
+    {
+        var responseBody = await ExecuteHttpGetRequestAsync();
+        var outputLines = responseBody.Split('\n');
+        Assert.Equal(1001, outputLines.Length);
+    }
+}

functions/responsestreaming/StreamBigQuery/Function.cs

@@ -0,0 +1,48 @@
+// Copyright 2023 Google LLC
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     https://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+// [START functions_response_streaming]
+
+using Google.Cloud.Functions.Framework;
+using Microsoft.AspNetCore.Http;
+using System.Threading.Tasks;
+using Google.Cloud.BigQuery.V2;
+using System;
+
+namespace StreamBigQuery;
+
+public class Function : IHttpFunction
+{
+    public async Task HandleAsync(HttpContext context)
+    {
+        context.Response.ContentType = "text/plain";
+        string projectId = Environment.GetEnvironmentVariable("GOOGLE_PROJECT_ID");
+        BigQueryClient client = BigQueryClient.Create(projectId).WithDefaultLocation(Locations.UnitedStates);
+
+        // Example to retrieve a large payload from BigQuery public dataset.
+        string query = "SELECT title FROM `bigquery-public-data.breathe.bioasq` LIMIT 1000";
+        BigQueryParameter[] parameters = null;
+        BigQueryResults results = client.ExecuteQuery(query, parameters);
+
+        // Stream out the payload response by iterating rows.
+        foreach (BigQueryRow row in results)
+        {
+            await context.Response.WriteAsync($"{row["title"]}\n");
+            // Artificially add a 50ms delay per line, just to make the streaming nature clearer
+            // when viewing the results in a browser.
+            await Task.Delay(50);
+        }
+    }
+}
+// [END functions_response_streaming]

functions/responsestreaming/StreamBigQuery/StreamBigQuery.csproj

@@ -0,0 +1,12 @@
+<Project Sdk="Microsoft.NET.Sdk">
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net6.0</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Google.Cloud.BigQuery.V2" Version="3.4.0" />
+    <PackageReference Include="Google.Cloud.Functions.Hosting" Version="2.1.0" />
+    <None Include="appsettings*.json" CopyToOutputDirectory="PreserveNewest" />
+  </ItemGroup>
+</Project>

functions/responsestreaming/runTests.ps1

@@ -0,0 +1,16 @@
+# Copyright 2023 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+dotnet restore --force
+dotnet test --no-restore --test-adapter-path:. --logger:junit 2>&1 | %{ "$_" }