1 package au.gov.amsa.streams;
2
3 import org.slf4j.Logger;
4 import org.slf4j.LoggerFactory;
5
6 import rx.plugins.RxJavaErrorHandler;
7 import rx.plugins.RxJavaPlugins;
8
9 public class RxJava {
10
11 private static final Logger log = LoggerFactory.getLogger(RxJava.class);
12
13 public static void setErrorHandler() {
14 RxJavaErrorHandler handler = new RxJavaErrorHandler() {
15
16 @Override
17 public void handleError(Throwable e) {
18 log.error(e.getMessage(), e);
19 }
20 };
21 RxJavaPlugins.getInstance().registerErrorHandler(handler);
22 }
23
24 }