package com.github.eventasia.eventstore.stream;

import com.github.eventasia.framework.Event;
import org.springframework.stereotype.Component;

import java.util.Observable;

@Component
public class ObservableEventStreamImpl<E extends Event> extends Observable implements EventStream<E> {

    public void postEvent(E event) {
        setChanged();
        notifyObservers(event);
    }

}

@@ -87,16 +87,98 @@
 .Event;%0A
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;%0A
 import o
@@ -260,16 +260,61 @@
 mponent%0A
+@ConditionalOnMissingBean(EventStream.class)%0A
 public c

add conditional annotation