Ensure the cancellationHandler is called if present when completion received

jabeattie · jabeattie · commit 11cedcd339fd · 2021-03-29T07:56:27.000+01:00
diff --git a/Sources/Subjects/ReplaySubject.swift b/Sources/Subjects/ReplaySubject.swift
@@ -137,6 +137,7 @@ extension ReplaySubject {
 
         func forwardCompletionToBuffer(_ completion: Subscribers.Completion<Failure>) {
             demandBuffer?.complete(completion: completion)
+            cancel()
         }
 
         func request(_ demand: Subscribers.Demand) {

Original file line number	Diff line number	Diff line change
`@@ -137,6 +137,7 @@ extension ReplaySubject {`
`137`	`137`
`138`	`138`	`func forwardCompletionToBuffer(_ completion: Subscribers.Completion<Failure>) {`
`139`	`139`	`demandBuffer?.complete(completion: completion)`
	`140`	`+ cancel()`
`140`	`141`	`}`
`141`	`142`
`142`	`143`	`func request(_ demand: Subscribers.Demand) {`