@extensionmethod(Observable)
def take_until(self, other):

    source = self
    other = Observable.from_future(other)

    def subscribe(observer):

        def on_completed(x):
            observer.on_completed()

        return CompositeDisposable(
            source.subscribe(observer),
            other.subscribe(on_completed, observer.on_error, noop)
        )
    return AnonymousObservable(subscribe)
Add the geometry to this Geometry Collection.
dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/takeuntil.py/take_until--crossover with--dataset/ETHPy150Open django/django/django/contrib/gis/gdal/geometries.py/GeometryCollection.add