pybeehive.asyn package

Submodules

pybeehive.asyn.core module

class pybeehive.asyn.core.Listener(filters=None)[source]

Bases: pybeehive.core.Listener

notify(event)[source]
Parameters:event –
Returns:
on_event(event)[source]
Parameters:event –
Returns:
setup()[source]
teardown()[source]
class pybeehive.asyn.core.Streamer(topic=None)[source]

Bases: pybeehive.core.Streamer

run()[source]
setup()[source]
stream()[source]
Returns:
teardown()[source]

pybeehive.asyn.hive module

class pybeehive.asyn.hive.Hive[source]

Bases: pybeehive.hive.Hive

pybeehive.asyn.socket module

class pybeehive.asyn.socket.Client(address)[source]

Bases: pybeehive.core.Killable

connect()[source]
send(data)[source]
shutdown()[source]
class pybeehive.asyn.socket.Server(address)[source]

Bases: pybeehive.core.Killable

iter_messages()[source]
shutdown()[source]
start()[source]
class pybeehive.asyn.socket.SocketListener(address, filters=None)[source]

Bases: pybeehive.asyn.core.Listener

on_event(event)[source]
Parameters:event –
Returns:
parse_event(event)[source]
setup()[source]
teardown()[source]
class pybeehive.asyn.socket.SocketStreamer(address, topic=None)[source]

Bases: pybeehive.asyn.core.Streamer

setup()[source]
stream()[source]
Returns:
teardown()[source]

pybeehive.asyn.utils module

class pybeehive.asyn.utils.AsyncContextManager(gen)[source]

Bases: object

class pybeehive.asyn.utils.AsyncGenerator(f, *args, **kwargs)[source]

Bases: object

pybeehive.asyn.utils.async_generator(f)[source]

Module contents

class pybeehive.asyn.Event(data, topic=None, created_at=None)[source]

Bases: object

Parameters:
  • data –
  • topic –
  • created_at –
static create_id(data, time_created)[source]
Parameters:
  • data –
  • time_created –
Returns:
static fromstring(string)[source]
Parameters:string –
Returns:
tostring()[source]
Returns:
class pybeehive.asyn.Listener(filters=None)[source]

Bases: pybeehive.core.Listener

notify(event)[source]
Parameters:event –
Returns:
on_event(event)[source]
Parameters:event –
Returns:
setup()[source]
teardown()[source]
class pybeehive.asyn.Streamer(topic=None)[source]

Bases: pybeehive.core.Streamer

run()[source]
setup()[source]
stream()[source]
Returns:
teardown()[source]
class pybeehive.asyn.Hive[source]

Bases: pybeehive.hive.Hive

pybeehive.asyn.async_generator(f)[source]