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

remove weblux files

Browse Source
This commit is contained in:
Erdem 2018-05-04 00:53:01 +03:00
parent 1fe62a811c
commit c8b44cc141
4 changed files with 0 additions and 90 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/Event.java
View File

@ -1,13 +0,0 @@
package com.baeldung.reactive.webflux;
import lombok.AllArgsConstructor;
import lombok.Data;
@Data
@AllArgsConstructor
public class Event {
private Long id;
private String body;
}

20
spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/EventStreamController.java
View File

@ -1,20 +0,0 @@
package com.baeldung.reactive.webflux;
import java.time.Duration;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;
@RestController
public class EventStreamController {
@GetMapping(value = "/events", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<Event> getEvents() {
return Flux.interval(Duration.ofMillis(1000))
.map(tick -> new Event(tick, "This is Event #" + tick));
}
}

12
spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/WebfluxDemoApplication.java
View File

@ -1,12 +0,0 @@
package com.baeldung.reactive.webflux;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class WebfluxDemoApplication {
public static void main(String[] args) {
SpringApplication.run(WebfluxDemoApplication.class, args);
}
}

45
spring-5-reactive/src/main/resources/static/webflux/client-event-stream.html
View File

@ -1,45 +0,0 @@
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>Baeldung: Spring 5 Reactive Webflux - real time event streaming</title>
<style type="text/css">
tr:nth-child(even) {background: lightgray}
tr:nth-child(odd) {background: white}
th {background: gray; text-align: left;}
</style>
</head>
<body>
<h1>Events streamed...</h1>
<table id="events-table" >
<thead>
<tr>
<th>Event Id</th>
<th>Event Body</th>
</tr>
</thead>
</table>
<script>
var eventSource = new EventSource("/events");
eventSource.onmessage = function (event) {
var data = JSON.parse(event.data);
var table = document.getElementById("events-table");
var row = table.insertRow(1);
var cellId = row.insertCell(0);
var cellBody = row.insertCell(1);
cellId.innerHTML = '<td>' + data.id + '</td>';
cellBody.innerHTML = '<td>' + data.body + '</td>';
}
</script>
</body>
</html>