huahaofeng
/
aspnetcore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Missed update after rebasing

This commit is contained in:
John Luo 2015-12-18 14:48:13 -08:00
parent bd10d507f8
commit 9edd6f60b9
1 changed files with 28 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
test/Microsoft.AspNet.Server.Kestrel.FunctionalTests/ReuseStreamsTests.cs
View File

@ -30,23 +30,24 @@ namespace Microsoft.AspNet.Server.Kestrel.FunctionalTests
}) })
.Build(); .Build();
var hostBuilder = new WebHostBuilder(config); var builder = new WebApplicationBuilder()
hostBuilder.UseServerFactory("Microsoft.AspNet.Server.Kestrel"); .UseConfiguration(config)
hostBuilder.UseStartup(app => .UseServerFactory("Microsoft.AspNet.Server.Kestrel")
{ .Configure(app =>
var serverInfo = app.ServerFeatures.Get<IKestrelServerInformation>();
app.Run(context =>
{ {
if (context.Request.Body != lastStream) var serverInfo = app.ServerFeatures.Get<IKestrelServerInformation>();
app.Run(context =>
{ {
lastStream = context.Request.Body; if (context.Request.Body != lastStream)
streamCount++; {
} lastStream = context.Request.Body;
return context.Request.Body.CopyToAsync(context.Response.Body); streamCount++;
}); }
}); return context.Request.Body.CopyToAsync(context.Response.Body);
});
});
using (var app = hostBuilder.Build().Start()) using (var app = builder.Build().Start())
{ {
using (var client = new HttpClient()) using (var client = new HttpClient())
{ {
@ -84,21 +85,22 @@ namespace Microsoft.AspNet.Server.Kestrel.FunctionalTests
}) })
.Build(); .Build();
var hostBuilder = new WebHostBuilder(config); var hostBuilder = new WebApplicationBuilder()
hostBuilder.UseServerFactory("Microsoft.AspNet.Server.Kestrel"); .UseConfiguration(config)
hostBuilder.UseStartup(app => .UseServerFactory("Microsoft.AspNet.Server.Kestrel")
{ .Configure(app =>
var serverInfo = app.ServerFeatures.Get<IKestrelServerInformation>();
app.Run(context =>
{ {
if (context.Request.Body != lastStream) var serverInfo = app.ServerFeatures.Get<IKestrelServerInformation>();
app.Run(context =>
{ {
lastStream = context.Request.Body; if (context.Request.Body != lastStream)
streamCount++; {
} lastStream = context.Request.Body;
return context.Request.Body.CopyToAsync(context.Response.Body); streamCount++;
}
return context.Request.Body.CopyToAsync(context.Response.Body);
});
}); });
});
using (var app = hostBuilder.Build().Start()) using (var app = hostBuilder.Build().Start())
{ {