Skip to content

Commit 93a7454

Browse files
merge PR: dotnet#351
1 parent 9daaae6 commit 93a7454

File tree

2 files changed

+13
-1
lines changed

2 files changed

+13
-1
lines changed

src/Docker.DotNet/Microsoft.Net.Http.Client/BufferedReadStream.cs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -218,6 +218,9 @@ private async Task EnsureBufferedAsync(CancellationToken cancel)
218218
#else
219219
_bufferCount = await _inner.ReadAsync(_buffer, _bufferOffset, _buffer.Length, cancel).ConfigureAwait(false);
220220
#endif
221+
222+
ThrowIfDisposed();
223+
221224
if (_bufferCount == 0)
222225
{
223226
throw new IOException("Unexpected end of stream");

test/Docker.DotNet.Tests/ISystemOperations.Tests.cs

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,16 @@ public async Task MonitorEventsAsync_Succeeds()
9090
await _client.Images.DeleteImageAsync($"{repository}:{tag}", new ImageDeleteParameters());
9191
}
9292

93-
93+
[Fact]
94+
public async Task MonitorEventsAsync_EmptyContainersList_CanBeCancelled()
95+
{
96+
var cts = new CancellationTokenSource();
97+
cts.CancelAfter(1000);
98+
99+
var task = _client.System.MonitorEventsAsync(new ContainerEventsParameters(), new Progress(), cts.Token);
100+
101+
await task;
102+
}
94103

95104
class Progress : IProgress<Message>
96105
{

0 commit comments

Comments
 (0)