``` venueRepository.getAllVenues() ...

# rx

[ursus]

venueRepository.getAllVenues()
                .map(venues -> {
                    if (venues.size() == 0) {
                        return new Event.Started();
                    } else {
                        return new Event.Finished();
                    }
                })
                .subscribe(eventsRelay);

but this doesn handle that second part