<dependencies>
<dependency>
<groupId>org.reactiverse</groupId>
<artifactId>reactive-collections</artifactId>
<version>1.0.0</version>
</dependency>
</dependencies>
ReactiveList<String> reactiveList = new ReactiveArrayList<>();
reactiveList.addObserver(new ReactiveObserver<String>() {
@Override
public void onNext(String element) {
System.out.println("Element added: " + element);
}
});
reactiveList.stream()
