Google Appengine и rx-Java?

Проблема заключается в ограничении потоков Java в Google Appengine: https://developers.google.com/appengine/docs/java/#Java_The_sandbox

RxJava использует Java Thread и Executor в реализациях Scheduler. Таким образом, коды, в которые вовлечены некоторые параллельные Scheduler, не могут работать в песочнице Google Java.

Если вы хотите использовать Scheduler в Google Appengine, вам нужно самостоятельно реализовать специальный Scheduler. Кроме того, некоторые операторы могут использовать Scheduler по умолчанию, например, delay по умолчанию использует Schedulers.computation(). Не забудьте использовать их Scheduler методы перегрузки.

Вы должны создать дочерний элемент RxJavaSchedulersHook и переопределить его методы с помощью вашего планировщика, который использует com.google.appengine.api.ThreadManager: я сделал это следующим образом:

public class MyThreadSchedulersHook extends RxJavaSchedulersHook {

private final Executor executor = new ScheduledThreadPoolExecutor(10, ThreadManager.backgroundThreadFactory());

@Override
public Scheduler getComputationScheduler() {
    return Schedulers.from(executor);
}

@Override
public Scheduler getIOScheduler() {
    return Schedulers.from(executor);
}

@Override
public Scheduler getNewThreadScheduler() {
    return Schedulers.from(executor);
}
}

Тогда вам следует зарегистрировать этот хук. Лучше сделать это в реализации ServletContextListener:

public class ContextListener implements ServletContextListener {

@Override
public void contextInitialized(final ServletContextEvent servletContextEvent) {
    RxJavaPlugins.getInstance().registerSchedulersHook(new RxMainThreadSchedulersHook());
}

@Override
public void contextDestroyed(final ServletContextEvent servletContextEvent) {
    // App Engine does not currently invoke this method.
}
}

Меня устраивает.