SseEmitter con Spring

gistfile1.txt

	@RequestMapping("/helloCount")
	SseEmitter mine() {
	    final SseEmitter sseEmitter = new SseEmitter();
	    
	    Observable.just(1,2,3,4,5,6,7,8,9,10)
		.map(t -> t + t)
		.observeOn(Schedulers.computation())
	    .subscribe(new Subscriber<Integer>() {

            @Override
            public void onCompleted() {
                sseEmitter.complete();
            }

            @Override
            public void onError(Throwable e) {
               sseEmitter.completeWithError(e);
            }

            @Override
            public void onNext(Integer t) {
            	
            	
                try {
                	Thread.sleep(2000);
					sseEmitter.send(t);
					System.out.println("ENVIADO " + t);
				} catch (Exception e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
            }

        });
		
	    
	 
	    return sseEmitter;
	}