Class LocalizableRowsSubscription<T extends LocalizableRow>
java.lang.Object
de.hybris.platform.util.localization.jdbc.rx.subscriptions.LocalizableRowsSubscription<T>
- 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 Object
implements rx.Observable.OnSubscribe<T>
-
Constructor Summary
ConstructorsConstructorDescriptionLocalizableRowsSubscription(DataSource dataSource, ExecutorService executorService, LocalizableRowsQuery<T> queryWithMapper) -
Method Summary
-
Constructor Details
-
LocalizableRowsSubscription
public LocalizableRowsSubscription(DataSource dataSource, ExecutorService executorService, LocalizableRowsQuery<T> queryWithMapper)
-
-
Method Details
-
call
- Specified by:
callin interfacerx.functions.Action1<T extends LocalizableRow>
-