         @connectPort socket, from, edge.from.port, false
 
         @connections.push socket
+        callback() if callback
 
     removeEdge: (edge) ->
         for connection,index in @connections

                    connection.from.process.component.inPorts[connection.from.port].detach connection
                    @connections.splice index, 1

    addInitial: (initializer) ->
        socket = internalSocket.createSocket()
        @addDebug socket if @debug


        unless to.component.isReady() or to.component.inPorts[initializer.to.port]
            to.component.setMaxListeners 0
            to.component.once "ready", =>
                @addInitial initializer, callback
            return

        @connectPort socket, to, initializer.to.port, true
