diff --git a/src/R3/Subject.cs b/src/R3/Subject.cs index daae810d..e7fca955 100644 --- a/src/R3/Subject.cs +++ b/src/R3/Subject.cs @@ -143,6 +143,11 @@ public Subject() list = new FreeListCore(this); // use self as gate(reduce memory usage), this is slightly dangerous so don't lock this in user. } + public Subject(CancellationToken cancellationToken) : this() + { + this.RegisterTo(cancellationToken); + } + public bool IsDisposed => completeState.IsDisposed; public void OnNext(T value)