// We can't validate that we hold the semaphore, but we can at least validate that someone is holding it.
Debug.Assert(_writerLock.CurrentCount == 0);
- EndWrite(false);
+ EndWrite(forceFlush: false);
}
private void EndWrite(bool forceFlush)
// We should not reach retry limit without failing.
Assert.NotEqual(0, maxCount);
- var headers = new HttpHeaderData[] { new HttpHeaderData("x-last", "done") };
- await connection.SendResponseHeadersAsync(streamId, endStream: true, isTrailingHeader : true, headers: headers);
try
{
await connection.SendGoAway(streamId);