diff --git a/spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventStreamingApplication.java b/spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventStreamingApplication.java
deleted file mode 100644
index 5deff35fa7..0000000000
--- a/spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventStreamingApplication.java
+++ /dev/null
@@ -1,38 +0,0 @@
-package com.baeldung.reactive.webflux.eventstreaming;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.context.annotation.Bean;
-import org.springframework.web.reactive.HandlerMapping;
-import org.springframework.web.reactive.handler.SimpleUrlHandlerMapping;
-import org.springframework.web.reactive.socket.WebSocketHandler;
-import org.springframework.web.reactive.socket.server.support.WebSocketHandlerAdapter;
-
-@SpringBootApplication
-public class EventStreamingApplication {
-
-	public static void main(String[] args) {
-		SpringApplication.run(EventStreamingApplication.class, args);
-	}
-
-	
-	@Bean
-	public HandlerMapping webSocketMapping() {
-		Map<String, WebSocketHandler> map = new HashMap<>();
-		map.put("/events", new EventWebSocketHandler());
-
-		SimpleUrlHandlerMapping mapping = new SimpleUrlHandlerMapping();
-		mapping.setUrlMap(map);
-		mapping.setOrder(1);
-		return mapping;
-	}
-
-	@Bean
-	public WebSocketHandlerAdapter handlerAdapter() {
-		return new WebSocketHandlerAdapter();
-	}
-	
-}
diff --git a/spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventWebSocketClient.java b/spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventWebSocketClient.java
deleted file mode 100644
index 357a5677c1..0000000000
--- a/spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventWebSocketClient.java
+++ /dev/null
@@ -1,26 +0,0 @@
-package com.baeldung.reactive.webflux.eventstreaming;
-
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.time.Duration;
-
-import org.springframework.web.reactive.socket.WebSocketMessage;
-import org.springframework.web.reactive.socket.client.ReactorNettyWebSocketClient;
-import org.springframework.web.reactive.socket.client.WebSocketClient;
-
-public class EventWebSocketClient {
-
-	private static final String REMOTE_URL = "ws://localhost:8080/events";
-
-    public static void main(String[] args) throws URISyntaxException {
-		
-		WebSocketClient client = new ReactorNettyWebSocketClient();
-		
-		client.execute(
-		          URI.create(REMOTE_URL), 
-		          session -> session.receive()
-		              .map(WebSocketMessage::getPayloadAsText)
-		              .log().then())
-		            .block(Duration.ofMinutes(10L));
-	}
-}
diff --git a/spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventWebSocketHandler.java b/spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventWebSocketHandler.java
deleted file mode 100644
index 37deaf3d1b..0000000000
--- a/spring-5-reactive/src/main/java/com/baeldung/reactive/webflux/eventstreaming/EventWebSocketHandler.java
+++ /dev/null
@@ -1,27 +0,0 @@
-package com.baeldung.reactive.webflux.eventstreaming;
-
-import java.text.MessageFormat;
-import java.time.Duration;
-import java.time.LocalTime;
-import java.util.UUID;
-
-import org.springframework.web.reactive.socket.WebSocketHandler;
-import org.springframework.web.reactive.socket.WebSocketSession;
-
-import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
-
-public class EventWebSocketHandler implements WebSocketHandler {
-
-    MessageFormat mf = new MessageFormat("EventID: {0} , Event Time: {1}") ;
-    
-    @Override
-    public Mono<Void> handle(WebSocketSession session) {
-        return session.send(
-            Flux.<String> generate(sink -> sink.next(
-                mf.format(new Object[] {UUID.randomUUID(),LocalTime.now()})))
-            .delayElements(Duration.ofSeconds(1))
-            .map(session::textMessage));
-    }
-
-}