diff --git a/src/FSharpx.Async/BlockingQueueAgent.fs b/src/FSharpx.Async/BlockingQueueAgent.fs index d5125c5..194a2f1 100644 --- a/src/FSharpx.Async/BlockingQueueAgent.fs +++ b/src/FSharpx.Async/BlockingQueueAgent.fs @@ -97,3 +97,7 @@ type BlockingQueueAgent<'T>(maxLength) = /// Gets the number of elements currently waiting in the queue. member x.Count = count + + interface IDisposable with + member _.Dispose() = + (agent :> IDisposable).Dispose() \ No newline at end of file