Add setPreAuthenticationChecks to Reactive Manager

core/src/main/java/org/springframework/security/authentication/AbstractUserDetailsReactiveAuthenticationManager.java

@@ -177,6 +177,17 @@ public void setUserDetailsPasswordService(ReactiveUserDetailsPasswordService use
 		this.userDetailsPasswordService = userDetailsPasswordService;
 	}
 
+	/**
+	 * Sets the strategy which will be used to validate the loaded <tt>UserDetails</tt>
+	 * object before authentication occurs.
+	 * @param preAuthenticationChecks The {@link UserDetailsChecker}
+	 * @since 7.1
+	 */
+	public void setPreAuthenticationChecks(UserDetailsChecker preAuthenticationChecks) {
+		Assert.notNull(preAuthenticationChecks, "preAuthenticationChecks cannot be null");
+		this.preAuthenticationChecks = preAuthenticationChecks;
+	}
+
 	/**
 	 * Sets the strategy which will be used to validate the loaded <tt>UserDetails</tt>
 	 * object after authentication occurs.

core/src/test/java/org/springframework/security/authentication/UserDetailsRepositoryReactiveAuthenticationManagerTests.java

@@ -69,6 +69,9 @@ public class UserDetailsRepositoryReactiveAuthenticationManagerTests {
 	@Mock
 	private Scheduler scheduler;
 
+	@Mock
+	private UserDetailsChecker preAuthenticationChecks;
+
 	@Mock
 	private UserDetailsChecker postAuthenticationChecks;
 
@@ -149,6 +152,25 @@ public void authenticateWhenPasswordServiceAndUpgradeFalseThenNotUpdated() {
 		verifyNoMoreInteractions(this.userDetailsPasswordService);
 	}
 
+	@Test
+	public void setPreAuthenticationChecksWhenNullThenIllegalArgumentException() {
+		assertThatExceptionOfType(IllegalArgumentException.class)
+			.isThrownBy(() -> this.manager.setPreAuthenticationChecks(null));
+	}
+
+	@Test
+	public void authenticateWhenPreAuthenticationChecksFail() {
+		given(this.userDetailsService.findByUsername(any())).willReturn(Mono.just(this.user));
+		willThrow(new LockedException("account is locked")).given(this.preAuthenticationChecks).check(any());
+		this.manager.setPreAuthenticationChecks(this.preAuthenticationChecks);
+		assertThatExceptionOfType(LockedException.class)
+			.isThrownBy(() -> this.manager
+				.authenticate(UsernamePasswordAuthenticationToken.unauthenticated(this.user, this.user.getPassword()))
+				.block())
+			.withMessage("account is locked");
+		verify(this.preAuthenticationChecks).check(eq(this.user));
+	}
+
 	@Test
 	public void authenticateWhenPostAuthenticationChecksFail() {
 		given(this.userDetailsService.findByUsername(any())).willReturn(Mono.just(this.user));