Package de.hybris.platform.util.localization.jdbc.rx.subscriptions

Class LocalizableRowsSubscription<T extends LocalizableRow>

  • All Implemented Interfaces:
    rx.functions.Action, rx.functions.Action1<rx.Subscriber<? super T>>, rx.functions.Function, rx.Observable.OnSubscribe<T>
    public class LocalizableRowsSubscription<T extends LocalizableRow>
extends java.lang.Object
implements rx.Observable.OnSubscribe<T>

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void call​(rx.Subscriber<? super T> subscriber)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • LocalizableRowsSubscription

        public LocalizableRowsSubscription​(javax.sql.DataSource dataSource,
                                   java.util.concurrent.ExecutorService executorService,
                                   LocalizableRowsQuery<T> queryWithMapper)

    • Method Detail

      • call

        public void call​(rx.Subscriber<? super T> subscriber)
        Specified by:
        call in interface rx.functions.Action1<T extends LocalizableRow>