java - RxJava thread-safety

Question

Is this code thread-safe?

Observable<String> observable = ... // some observable that calls
                                    // onNext from a background thread

observable
  .scan(new ArrayList<String>(), (List<String> acc, String next) -> {
    acc.add(next);
    return acc;
  })
  .subscribe( list -> {
    // do somethind with sequence of lists
    ...
  });

I'm curious because ArrayList is not a thread-safe data structure.

Answer 1

このコードがスレッドセーフでない場合は、RxJava が壊れているか、Observable ソースが壊れているかのいずれかです。オペレータが再入不可であることは、Rx コントラクトの一部です。