diff --git a/src/main/java/ru/touchin/roboswag/core/observables/collections/ObservableCollection.java b/src/main/java/ru/touchin/roboswag/core/observables/collections/ObservableCollection.java index e1907f0..1712358 100644 --- a/src/main/java/ru/touchin/roboswag/core/observables/collections/ObservableCollection.java +++ b/src/main/java/ru/touchin/roboswag/core/observables/collections/ObservableCollection.java @@ -69,7 +69,7 @@ public abstract class ObservableCollection implements Serializable { subscriber.onNext(getItems()); subscriber.onCompleted(); }) - .switchMap(ignored -> observeChanges().map(changes -> getItems())) + .switchMap(initialItems -> Observable.just(initialItems).concatWith(observeChanges().map(changes -> getItems()))) .replay(1) .refCount(); }