Create 'setup' query / observable for events

[andreassimon]

Wahrscheinlich zusammenhängend mit #16.

Implementierungsmöglichkeiten:

interface Observer {
    onCompleted()
    onError()
    onNext(next)
}

eventSource.past(Map<> criteria).fold(...).map(...).subscribe(Observer o)
eventSource.future(Map<> criteria).fold(...).map(...).subscribe(Observer o)