mPyPl.sink
index
d:\winapp\anaconda3\lib\site-packages\mpypl\sink.py

# mPyPl - Monadic Pipeline Library for Python
http://github.com/shwars/mPyPl

 
Modules
       
csv
json

 
Pipe functions
       
add(x)
aggregate(iterable, function, **kwargs)
all(iterable, pred)
Returns True if ALL elements in the given iterable are true for the
given pred function
any(iterable, pred)
Returns True if ANY element in the given iterable is True for the
given pred function
as_dict(iterable)
as_list(iterable)
as_set(iterable)
as_tuple(iterable)
average(iterable)
Build the average for the given iterable, starting with 0.0 as seed
Will try a division by 0 if the iterable is empty...
chain(iterable)

 
chain_with = class chain(builtins.object)
    chain(*iterables) --> chain object
 
Return a chain object whose .__next__() method returns elements from the
first iterable until it is exhausted, then elements from the next
iterable, until all of the iterables are exhausted.
 
  Methods defined here:
__getattribute__(self, name, /)
Return getattr(self, name).
__iter__(self, /)
Implement iter(self).
__new__(*args, **kwargs) from builtins.type
Create and return a new object.  See help(type) for accurate signature.
__next__(self, /)
Implement next(self).
__reduce__(...)
Return state information for pickling.
__setstate__(...)
Set state information for unpickling.
from_iterable(...) from builtins.type
chain.from_iterable(iterable) --> chain object
 
Alternate chain() constructor taking a single iterable argument
that evaluates lazily.

concat(iterable, separator=', ')
count(iterable)
Count the size of the given iterable, walking thrue it.
dedup(iterable)
Only yield unique items. Use a set to keep track of duplicate data.
first(iterable)
groupby(iterable, keyfunc)
index(iterable, value, start=0, stop=None)

 
class islice(builtins.object)
    islice(iterable, stop) --> islice object
islice(iterable, start, stop[, step]) --> islice object
 
Return an iterator whose next() method returns selected values from an
iterable.  If start is specified, will skip all preceding elements;
otherwise, start defaults to zero.  Step defaults to one.  If
specified as another value, step determines how many values are 
skipped between successive calls.  Works like a slice() on a list
but returns an iterator.
 
  Methods defined here:
__getattribute__(self, name, /)
Return getattr(self, name).
__iter__(self, /)
Implement iter(self).
__new__(*args, **kwargs) from builtins.type
Create and return a new object.  See help(type) for accurate signature.
__next__(self, /)
Implement next(self).
__reduce__(...)
Return state information for pickling.
__setstate__(...)
Set state information for unpickling.

 
izip = class zip(object)
    zip(iter1 [,iter2 [...]]) --> zip object
 
Return a zip object whose .__next__() method returns a tuple where
the i-th element comes from the i-th iterable argument.  The .__next__()
method continues until the shortest iterable in the argument sequence
is exhausted and then it raises StopIteration.
 
  Methods defined here:
__getattribute__(self, name, /)
Return getattr(self, name).
__iter__(self, /)
Implement iter(self).
__new__(*args, **kwargs) from builtins.type
Create and return a new object.  See help(type) for accurate signature.
__next__(self, /)
Implement next(self).
__reduce__(...)
Return state information for pickling.

lineout(x)
lstrip(iterable, chars=None)
max(iterable, **kwargs)
min(iterable, **kwargs)
netcat(to_send, host, port)
netwrite(to_send, host, port)
passed(x)
permutations(iterable, r=None)
reverse(iterable)
rstrip(iterable, chars=None)
run_with(iterable, func)
select(iterable, selector)
skip(iterable, qte)
Skip qte elements in the given iterable, then yield others.
skip_while(iterable, predicate)
sort(iterable, **kwargs)
stdout(x)
strip(iterable, chars=None)
t(iterable, y)
tail(iterable, qte)
Yield qte of elements in the given iterable.
take(iterable, qte)
Yield qte of elements in the given iterable.
take_while(iterable, predicate)
tee(iterable)
to_type(x, t)
transpose(iterable)
traverse(args)
uniq(iterable)
Deduplicate consecutive duplicate values.
where(iterable, predicate)
write_csv(l, filename)
write_json(l, filename)