You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
67 lines
2.4 KiB
67 lines
2.4 KiB
1 year ago
|
// original code from GitHub Reactive-Extensions/Rx.NET
|
||
|
|
// some modified.
|
||
|
|
|
||
|
|
// Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.
|
||
|
|
|
||
|
|
#if (NETFX_CORE || NET_4_6 || NET_STANDARD_2_0 || UNITY_WSA_10_0)
|
||
|
|
|
||
|
|
using System;
|
||
|
|
using System.Threading;
|
||
|
|
|
||
|
|
namespace UniRx
|
||
|
|
{
|
||
|
|
/// <summary>
|
||
|
|
/// Represents a disposable resource that has an associated <seealso cref="T:System.Threading.CancellationToken"/> that will be set to the cancellation requested state upon disposal.
|
||
|
|
/// </summary>
|
||
|
|
public sealed class CancellationDisposable : ICancelable
|
||
|
|
{
|
||
|
|
private readonly CancellationTokenSource _cts;
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Initializes a new instance of the <see cref="T:System.Reactive.Disposables.CancellationDisposable"/> class that uses an existing <seealso cref="T:System.Threading.CancellationTokenSource"/>.
|
||
|
|
/// </summary>
|
||
|
|
/// <param name="cts"><seealso cref="T:System.Threading.CancellationTokenSource"/> used for cancellation.</param>
|
||
|
|
/// <exception cref="ArgumentNullException"><paramref name="cts"/> is null.</exception>
|
||
|
|
public CancellationDisposable(CancellationTokenSource cts)
|
||
|
|
{
|
||
|
|
if (cts == null)
|
||
|
|
throw new ArgumentNullException("cts");
|
||
|
|
|
||
|
|
_cts = cts;
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Initializes a new instance of the <see cref="T:System.Reactive.Disposables.CancellationDisposable"/> class that uses a new <seealso cref="T:System.Threading.CancellationTokenSource"/>.
|
||
|
|
/// </summary>
|
||
|
|
public CancellationDisposable()
|
||
|
|
: this(new CancellationTokenSource())
|
||
|
|
{
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Gets the <see cref="T:System.Threading.CancellationToken"/> used by this CancellationDisposable.
|
||
|
|
/// </summary>
|
||
|
|
public CancellationToken Token
|
||
|
|
{
|
||
|
|
get { return _cts.Token; }
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Cancels the underlying <seealso cref="T:System.Threading.CancellationTokenSource"/>.
|
||
|
|
/// </summary>
|
||
|
|
public void Dispose()
|
||
|
|
{
|
||
|
|
_cts.Cancel();
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Gets a value that indicates whether the object is disposed.
|
||
|
|
/// </summary>
|
||
|
|
public bool IsDisposed
|
||
|
|
{
|
||
|
|
get { return _cts.IsCancellationRequested; }
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
#endif
|