iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'master' of https://github.com/micropatel/tutorials

Browse Source 
Removed unwanted class
This commit is contained in:
micropatel 2018-07-10 01:19:47 -03:00
commit 1c03ee9c42
2 changed files with 0 additions and 50 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
spring-5-reactive-client/src/test/java/com/baeldung/reactive/ReactiveEventClient.java
View File

@ -1,29 +0,0 @@
package com.baeldung.reactive;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Flux;
@SpringBootApplication
public class ReactiveEventClient implements CommandLineRunner {
public static void main(String[] args) {
System.setProperty("server.port","8090");
SpringApplication.run(ReactiveEventClient.class, args);
}
@Override
public void run(String... args) throws Exception {
WebClient webclient = WebClient.builder()
.defaultHeader(HttpHeaders.ACCEPT, MediaType.TEXT_EVENT_STREAM_VALUE)
.baseUrl("http://localhost:8080/events")
.build();
webclient.get().uri("/stream/").header(HttpHeaders.CONTENT_TYPE,MediaType.TEXT_HTML.toString())
.retrieve().bodyToFlux(String.class)
.subscribe(System.out::println);
}
}

21
spring-5-reactive/src/main/java/com/baeldung/reactive/controller/ReactiveEventServer.java
View File

@ -1,21 +0,0 @@
package com.baeldung.reactive.controller;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;
import java.time.Duration;
@RestController
@RequestMapping("/events")
public class ReactiveEventServer {
@GetMapping(path = "/stream/" , produces=MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<String> eventStream() {
return Flux.interval(Duration.ofSeconds(1)).map(tick -> {return "Event:" + tick;});
}
}