code: def asyncPipeUniq(context=None, _INPUT=None, conf=None, **kwargs):
      
      _input = yield _INPUT
      asyncFuncs = yield asyncGetSplits(None, conf, **cdicts(opts, kwargs))
      pieces = yield asyncFuncs[0]()
      _pass = yield asyncFuncs[2]()
  
      if _pass:
          _OUTPUT = _input
      else:
          start = int(pieces.start)
          stop = start + int(pieces.count)
          _OUTPUT = islice(_input, start, stop)
  
      returnValue(_OUTPUT)
docs: An operator that asynchronously returns a specified number of items from
      the top of a feed. Not loopable.
  
      Parameters
      ----------
      context : pipe2py.Context object
      _INPUT : twisted Deferred iterable of items
      conf : {
          'start': {'type': 'number', value': <starting location>}
          'count': {'type': 'number', value': <desired feed length>}
      }
  
      returns
      -------
      _OUTPUT : twisted.internet.defer.Deferred generator of unique items