Commits

Dhananjay Nene  committed 726252f

The join setting had gone awry with no merge happening. Fixed it.

  • Participants
  • Parent commits e9df814

Comments (0)

Files changed (1)

File rnd/initial/pyedpyper.py

                     # values for all handles received
                     keydict = vals.pop(key)
                     val = joinfunc(keydict)
-                    if target :
-                        target.send(val)
+                    if next :
+                        next.send(val)
                     
 ##############################################################################
 # Sample Usage
 # Declare a eventual join        
 joinpype = join(
                 ['contacts','fixedwidth'],
-                lambda dct : ":".join(dct['contacts'].email,dct['fixedwidth'][2]),
+                lambda dct : ":".join([dct['contacts'].email,dct['fixedwidth'][2]]),
                 True,
                 tracer('PostJoin')
             )            
             'fixedwidth',
             # Create a new data based on the expression below
             lambda x : x[0] + '@' + x[1],
-            # Trace as joined stream
-            tracer('Joined Stream')
+            # Merge it into the earlier stream (at joinpype)
+            joinpype
         )
     )
 )