jaclearn.dataflow.utils#

Classes

`DataFlowMixer`
`MapDataFlow`

Functions

`cycle`(iterable[, times])
`cycle_n`(iterable[, times])
`ssmap`(function, iterable)

Class DataFlowMixer

class DataFlowMixer[source]#

Bases: SimpleDataFlowBase

__init__(dataflows, buflen=None)[source]#

__new__(**kwargs)#

Class MapDataFlow

class MapDataFlow[source]#

Bases: ProxyDataFlowBase

__init__(other, map_func=None)[source]#

__new__(**kwargs)#

property unwrapped#

Functions

cycle(iterable, times=None)[source]#

cycle_n(iterable, times=None)#

ssmap(function, iterable)[source]#