caspia.reactive package

Subpackages

• caspia.reactive.operations package
  • Submodules
  • caspia.reactive.operations.cached module
  • caspia.reactive.operations.default module
  • caspia.reactive.operations.filter module
  • caspia.reactive.operations.impuls module
  • caspia.reactive.operations.lambda_ module
  • caspia.reactive.operations.lowpass module
  • caspia.reactive.operations.operators module
  • caspia.reactive.operations.transition module
  • Module contents

Submodules

caspia.reactive.disposables module

class caspia.reactive.disposables.AnonymousDisposable(action=None)

Bases: caspia.reactive.disposables.Disposable

dispose()

class caspia.reactive.disposables.Disposable

Bases: object

dispose()

caspia.reactive.errors module

exception caspia.reactive.errors.ValueNotReady

Bases: Exception

Should be raised from .observe() if observable has no value, yet.

args

with_traceback()

Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

caspia.reactive.observable module

class caspia.reactive.observable.Observable

Bases: typing.Generic

Represents reactive value.

It is possible to subscribe for its changes using .subscribe() and get its current value using .observe()

dispose_subscription(observer)

Remove subscription of given observer.

do(*args, **kwargs)

exception_handler(exception, stack, **kwargs)

async observe() → T

Return current value of the observable.

subscribe(*args, **kwargs)

Create observer using given *args and **kwargs and subscribe to its changes.

Returns disposable representing the subscription => call .dispose() to unsubscribe.

async trigger(value: T, **kwargs)

Manually trigger value change.

caspia.reactive.observers module

class caspia.reactive.observers.FunctionObserver

Bases: caspia.reactive.observers.Observer

static create(*args, **kwargs)

static creator(*args, **kwargs)

creators = [<function CharacteristicObserver.creator>, <function FunctionObserver.creator>]

disable()

enable()

property is_enabled

async on_error(error, **kwargs)

async on_next(value, **kwargs)

static register_creator(creator)

subscribe_error(on_error)

subscribe_next(on_next)

class caspia.reactive.observers.Observer

Bases: typing.Generic

static create(*args, **kwargs)

creators = [<function CharacteristicObserver.creator>, <function FunctionObserver.creator>]

disable()

enable()

property is_enabled

abstract async on_error(error, **kwargs)

abstract async on_next(value: T, **kwargs)

static register_creator(creator)

caspia.reactive.utils module

caspia.reactive.utils.extension_classmethod(base, name=None, alias=None)

caspia.reactive.utils.extension_method(base, name=None, decorator=None, instancemethod=False, alias=None)

caspia.reactive.value module

class caspia.reactive.value.Value(value)

Bases: caspia.reactive.observable.Observable

dispose_subscription(observer)

Remove subscription of given observer.

do(*args, **kwargs)

exception_handler(exception, stack, **kwargs)

async observe()

Return current value of the observable.

subscribe(*args, **kwargs)

Create observer using given *args and **kwargs and subscribe to its changes.

Returns disposable representing the subscription => call .dispose() to unsubscribe.

async trigger(value: T, **kwargs)

Manually trigger value change.

async update(value, notify=True)

update_without_notification(value)

Module contents