protected override async Task<int> ReadFromStreamAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken)
{
	var readTask = Stream
	   .ReadAsync(buffer, offset, length, cancellationToken);

	var tcs = new TaskCompletionSource<object?>();
	using var registration = cancellationToken.Register(() => tcs.TrySetResult(null));
	var resultTask = await Task.WhenAny(readTask, tcs.Task)
	   .ConfigureAwait(false);

	if (cancellationToken.IsCancellationRequested)
	{
		Logger?.LogTrace("Cancelled through CancellationToken");
		return 0;
	}
...