docs: protected Response handleRequest() {
  		ResponseBuilder builder = null;
  		/* ensure we aren't allowing more connections than we want */
  		int numberConnections = getCurrentConnections().get();
  		int maxNumberConnectionsAllowed = getMaxNumberConcurrentConnectionsAllowed(); // may change at runtime, so look this up for each request
  		if (numberConnections >= maxNumberConnectionsAllowed) {
  			builder = Response.status(Status.SERVICE_UNAVAILABLE).entity("MaxConcurrentConnections reached: " + maxNumberConnectionsAllowed);
  		} else {
  			/* initialize response */
  			builder = Response.status(Status.OK);
  			builder.header(HttpHeaders.CONTENT_TYPE, "text/event-stream;charset=UTF-8");
  			builder.header(HttpHeaders.CACHE_CONTROL, "no-cache, no-store, max-age=0, must-revalidate");
  			builder.header("Pragma", "no-cache");
  			getCurrentConnections().incrementAndGet();
  			builder.entity(new HystrixStream(sampleStream, pausePollerThreadDelayInMs, getCurrentConnections()));
  		}
  		return builder.build();
  
  	}