       # Randomize the rest of the entries to make sure we are always collating right
       original.sort -> 0.5 - Math.random()
 
-      for entry in original
+      # Send the beginning of transmission to all inputs
+      inport.connect() for inport in ins
+
+      for entry,index in original
         # Parse comma-separated
         entryData = entry.split ','
         # Convert to object

          entryObj[header] = entryData[idx]

        # Send to a random input port
        ins[Math.floor(Math.random()*ins.length)].send entryObj

      # Finally disconnect all
      inPort.disconnect() for inPort in ins

  beforeEach ->
    c = Collate.getComponent()
    cntl = noflo.internalSocket.createSocket()
    ins.push noflo.internalSocket.createSocket()
    ins.push noflo.internalSocket.createSocket()
    ins.push noflo.internalSocket.createSocket()
    out = noflo.internalSocket.createSocket()
