File tree Expand file tree Collapse file tree 1 file changed +3
-25
lines changed Expand file tree Collapse file tree 1 file changed +3
-25
lines changed Original file line number Diff line number Diff line change @@ -1030,19 +1030,7 @@ namespace web { namespace http
1030
1030
if (to_read == 0 )
1031
1031
{
1032
1032
ctx->m_body_buf .consume (CRLF.size ());
1033
- ctx->_get_writebuffer ().sync ()
1034
- .then ([ctx](pplx::task<void > op)
1035
- {
1036
- try
1037
- {
1038
- op.wait ();
1039
- ctx->complete_request (ctx->m_downloaded );
1040
- }
1041
- catch (...)
1042
- {
1043
- ctx->report_exception (std::current_exception ());
1044
- }
1045
- });
1033
+ ctx->complete_request (ctx->m_downloaded );
1046
1034
}
1047
1035
else
1048
1036
{
@@ -1129,18 +1117,8 @@ namespace web { namespace http
1129
1117
}
1130
1118
else
1131
1119
{
1132
- writeBuffer.sync ().then ([ctx](pplx::task<void > op)
1133
- {
1134
- try
1135
- {
1136
- op.wait ();
1137
- ctx->complete_request (ctx->m_downloaded );
1138
- }
1139
- catch (...)
1140
- {
1141
- ctx->report_exception (std::current_exception ());
1142
- }
1143
- });
1120
+ // Request is complete no more data to read.
1121
+ ctx->complete_request (ctx->m_downloaded );
1144
1122
}
1145
1123
}
1146
1124
};
You can’t perform that action at this time.
0 commit comments