From 8a95e5798dee7e2bf98c09f93e9bc8a96f704121 Mon Sep 17 00:00:00 2001
From: Eleftheria Stein <eleftheria.kousathana@gmail.com>
Date: Fri, 22 Nov 2019 16:26:12 +0100
Subject: [PATCH] Update @MessageMapping to match input/output cardinality

---
 .../rsocket/RSocketMessageHandlerITests.java      | 15 +--------------
 1 file changed, 1 insertion(+), 14 deletions(-)

diff --git a/config/src/test/java/org/springframework/security/config/annotation/rsocket/RSocketMessageHandlerITests.java b/config/src/test/java/org/springframework/security/config/annotation/rsocket/RSocketMessageHandlerITests.java
index ee555db1cd8..6af06326bfd 100644
--- a/config/src/test/java/org/springframework/security/config/annotation/rsocket/RSocketMessageHandlerITests.java
+++ b/config/src/test/java/org/springframework/security/config/annotation/rsocket/RSocketMessageHandlerITests.java
@@ -185,19 +185,6 @@ public void retrieveFluxWhenDataStringAndSecureThenDenied() throws Exception {
 		assertThat(this.controller.payloads).isEmpty();
 	}
 
-	@Test
-	public void retrieveFluxWhenDataStringAndPublicThenGranted() throws Exception {
-		String data = "a";
-		List<String> hi = this.requester.route("retrieve-flux")
-				.data(data)
-				.retrieveFlux(String.class)
-				.collectList()
-				.block();
-
-		assertThat(hi).contains("hello a");
-		assertThat(this.controller.payloads).containsOnly(data);
-	}
-
 	@Test
 	public void sendWhenSecureThenDenied() throws Exception {
 		String data = "hi";
@@ -287,7 +274,7 @@ Flux<String> retrieveFlux(Flux<String> payload) {
 		}
 
 		@MessageMapping({"secure.send", "send"})
-		Mono<Void> send(Flux<String> payload) {
+		Mono<Void> send(Mono<String> payload) {
 			return payload
 					.doOnNext(this::add)
 					.then(Mono.fromRunnable(() -> {