pswamp.streaming.base

Classes

`Producer`
`Consumer`
`BaseIO`

Module Contents

class pswamp.streaming.base.Producer(*args, type='kafka', **kwargs)

base_object

__getattr__(name)

class pswamp.streaming.base.Consumer(*args, type='kafka', **kwargs)

base_object

__getattr__(name)

__iter__()

__next__()

class pswamp.streaming.base.BaseIO(*args, type='kafka', **kwargs)

base_object

__getattr__(name)