tacone / pipes

docs/features.php

<?php

/**
 * A brief list of features we want in
 */

// iterator interface
p()->next();

The method next() does not seem to exist on object<Pipes\Pipe>.

p()->current();

The method current() does not seem to exist on object<Pipes\Pipe>.

p()->valid();

The method valid() does not seem to exist on object<Pipes\Pipe>.

p()->rewind();

The method rewind() does not seem to exist on object<Pipes\Pipe>.

p()->getInnerIterator();

The method getInnerIterator() does not seem to exist on object<Pipes\Pipe>.

// pipes
p()->chunk($num); // ok
p()->each($function, $step = 1); //ok

$step = 1 is of type integer, but the function expects a boolean.

p()->filter($function); //ok
p()->limit($skip = 0, $max); //ok
p()->map($function); //okdi

// factory methods
p()->emit($key = null, $value); //ok
p()->flags($flag1, $flag2 =null, $flagN = null);

The method flags() does not seem to exist on object<Pipes\Pipe>.

// terminals
p()->toValues(); // ok. outputs an indexed array.
p()->toArray(); // ok. outputs an array. Keys preserved (last key wins)
p()->toIterator(); // ok. outputs an array. Keys preserved (last key wins)
p()->reduce($function = null); // outputs an array. Keys preserved. Conflicts handled by $function

The method reduce() does not seem to exist on object<Pipes\Pipe>.

// timed pipes
p()->maxTime($seconds); //also floats 0.001 etc

The method maxTime() does not seem to exist on object<Pipes\Pipe>.

p()->wait($seconds, $function = null); // !$function ? wait again

The method wait() does not seem to exist on object<Pipes\Pipe>.

// push to other queues (array, queues, chains)
p()->filter($function, $queue);

$function is of type null, but the function expects a callable.

The call to Pipe::filter() has too many arguments starting with $queue.

p()->map($function, $queue);

$function is of type null, but the function expects a callable.

The call to Pipe::map() has too many arguments starting with $queue.

// accumulators
p()->groupBy($function);

The method groupBy() does not seem to exist on object<Pipes\Pipe>.

p()->sort();

The method sort() does not seem to exist on object<Pipes\Pipe>.

// queues
p()->queues->sqlite('queue.db');

The property queues does not seem to exist in Pipes\Pipe.

p()->queues->file('queue.txt');
p()->queues->json('queue.json'); // one json per line
p()->queues->post($url, $moreParams);

// anonymous pipes
$func = p()->filter($foo)->map($bar);
$result = $func('hello');

$func->wrap($array);

The method wrap() does not seem to exist on object<Pipes\Pipe>.

p($array)->map('p()->emit($k, $v)');

// --- advanced stuff

// caching
p()->keep(3)->each(function(){

The method keep() does not seem to exist on object<Pipes\Pipe>.

    $previous = p()->kept(-1); // also -2, -3

The method kept() does not seem to exist on object<Pipes\Pipe>.

$previous is not used, you could remove the assignment.

});

// map reduce
p()->shard($function);

The method shard() does not seem to exist on object<Pipes\Pipe>.

p()->reduce($shard);

The method reduce() does not seem to exist on object<Pipes\Pipe>.

/*

Figure out how to:

- properly replace an inneriterator with another in PipeIterator
- properly append new iterms in PipeIterator
- how to make PipeIterator a simple reference to a Pipe Instance

- Pipe iterator should not wrap the Pipe instance but iterate on its
inner iterator.
- Thus, a new Pipe iterator should be initialized for each chainWith
operation.
- Pipe iterator should keep an instance of its pipe for easy retrieval.
- Each chain operation on Pipe iterator should be passed on to its
  Pipe parent, but should be reflected on the iterator (?)

Should we return a new Pipe instance for each chainWith?
$pipe = p($collection)->filter('isEmpty');
$map = $pipe->map('myfunc')->each('func')->limit(3);
$discard = $pipe->each('logme');
$result = $map->toArray();
$discarded = $discard->toArray();

 */