func dispose()

in MobiusCore/Source/ConnectablePublisher.swift [69:80]


    func dispose() {
        let connections: [Connection<Value>] = access.guard {
            guard !_disposed else { return [] }

            _disposed = true
            return Array(self.connections.values)
        }

        // Again, this has to be outside the sync block to avoid recursive locking – in this case, recursion into
        // removeConnection().
        connections.forEach { $0.dispose() }
    }