private <T> void manageSubscription(EventStream<T> stream, Consumer<T> consumer) {
        manageSubscription(stream.subscribe(consumer));
    }
private < T > void manageSubscription ( EventStream < T > stream , Consumer < T > consumer ) { manageSubscription ( stream . subscribe ( consumer ) ) ; }
/* ********************************************************************** *
*
Private methods                                                        *
*
**********************************************************************