old_contents: # pipetruncate.py
  #
  
  from pipe2py import util
  
  def pipe_truncate(context, _INPUT, conf, **kwargs):
      """This operator truncates the number of items in a feed.
  
      Keyword arguments:
      context -- pipeline context
      _INPUT -- source generator
      kwargs -- terminal, if the truncation value is wired in
      conf:
          count -- length of the truncated feed, if specified literally
          
      Yields (_OUTPUT):
      truncated list of source items
      """
  
      count = conf['count']
      limit = int(util.get_value(count, None, **kwargs))
      for i in xrange(0, limit):
          yield _INPUT.next()
      
new_contents: # pipetruncate.py
  #
  
  from pipe2py import util
  
  def pipe_truncate(context, _INPUT, conf, **kwargs):
      """This operator truncates the number of items in a feed.
  
      Keyword arguments:
      context -- pipeline context
      _INPUT -- source generator
      kwargs -- terminal, if the truncation value is wired in
      conf:
          count -- length of the truncated feed, if specified literally
          
      Yields (_OUTPUT):
      truncated list of source items
      """
  
      count = conf['count']
      limit = int(util.get_value(count, None, **kwargs))
      i = 0
      for item in _INPUT:
          if i >= limit:
              break
          yield item
          i += 1
  
subject: Fix for taking feed from a split output