neuraxle.metaopt.observable

Neuraxle’s Observable Classes

Base observable classes

class neuraxle.metaopt.observable._Observable[source]
_abc_cache = <_weakrefset.WeakSet object>[source]
_abc_generic_negative_cache = <_weakrefset.WeakSet object>[source]
_abc_generic_negative_cache_version = 60
_abc_registry = <_weakrefset.WeakSet object>[source]
_gorg[source]

alias of _Observable

on_complete(value: T)[source]
on_error(value: Exception)[source]
on_next(value: T)[source]
subscribe(observer: neuraxle.metaopt.observable._Observer[T])[source]
unsubscribe(observer: neuraxle.metaopt.observable._Observer[T])[source]
class neuraxle.metaopt.observable._Observer[source]
_abc_cache = <_weakrefset.WeakSet object>[source]
_abc_generic_negative_cache = <_weakrefset.WeakSet object>[source]
_abc_generic_negative_cache_version = 60
_abc_registry = <_weakrefset.WeakSet object>[source]
_gorg[source]

alias of _Observer

on_complete(value: T)[source]
on_error(value: Exception)[source]
on_next(value: T)[source]