How to propery construct AsyncMessageBroker?

[KAW0]

I created AsyncMessageBroker based on example in readme but this cause memory leak.

using Cysharp.Threading.Tasks;
using Cysharp.Threading.Tasks.Linq;
using System;
using System.Collections.Generic;
using System.Threading;

public class AsyncMessageBroker<T> : IDisposable, IUniTaskAsyncEnumerable<T>
{
    Channel<T> channel;
    IConnectableUniTaskAsyncEnumerable<T> multicastSource;
    IDisposable connection;
    CancellationTokenSource cts;
    CancellationToken ct;
    public AsyncMessageBroker()
    {
        cts = new CancellationTokenSource();
        ct = cts.Token;      
        channel = Channel.CreateSingleConsumerUnbounded<T>();
        multicastSource = channel.Reader.ReadAllAsync(ct).Publish();
        connection = multicastSource.Connect();
    }
    public void Send(T value)
    {
        channel.Writer.TryWrite(value);
    }
    public virtual void Dispose()
    {
        channel.Writer.TryComplete();
        connection.Dispose();
        cts?.Dispose();
    }
    public IUniTaskAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellationToken = default)
    {
        if (cancellationToken == default)
            return multicastSource.GetAsyncEnumerator(ct);
        else
            return multicastSource.GetAsyncEnumerator(cancellationToken);
    }
}