func connect()

in MobiusCore/Source/EffectHandlers/ThreadSafeConnectable.swift [17:35]

• 18 lines of code
• 1 McCabe index (conditional complexity)

    func connect(_ output: @escaping (Event) -> Void) -> Connection<Effect> {
        return lock.synchronized {
            guard self.output == nil, connection == nil else {
                MobiusHooks.errorHandler(
                    "Connection limit exceeded: The Connectable \(type(of: self)) is already connected. " +
                    "Unable to connect more than once",
                    #file,
                    #line
                )
            }
            self.output = output
            connection = connectable.connect(self.dispatch)

            return Connection(
                acceptClosure: accept,
                disposeClosure: dispose
            )
        }
    }