apache_beam.coders.observable module

Observable base class for iterables.

For internal use only; no backwards-compatibility guarantees.

class apache_beam.coders.observable.ObservableMixin

Bases: future.types.newobject.newobject

For internal use only; no backwards-compatibility guarantees.

An observable iterable.

Subclasses need to call self.notify_observers with any object yielded.

register_observer(callback)

notify_observers(value, **kwargs)