committed by
Christoph Strobl
parent
87effb9013
commit
10acc14c14
@@ -446,7 +446,7 @@ public class ScriptOperators {
|
|||||||
/**
|
/**
|
||||||
* Define the optional {@code initArgs} for the {@link #init(String)} function.
|
* Define the optional {@code initArgs} for the {@link #init(String)} function.
|
||||||
*
|
*
|
||||||
* @param function must not be {@literal null}.
|
* @param args must not be {@literal null}.
|
||||||
* @return this.
|
* @return this.
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
@@ -117,8 +117,8 @@ public class GeoSpatialIndexTests extends AbstractIntegrationTests {
|
|||||||
/**
|
/**
|
||||||
* Returns whether an index with the given name exists for the given entity type.
|
* Returns whether an index with the given name exists for the given entity type.
|
||||||
*
|
*
|
||||||
* @param indexName
|
|
||||||
* @param entityType
|
* @param entityType
|
||||||
|
* @param type
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
private boolean hasIndexOfType(Class<?> entityType, final String type) {
|
private boolean hasIndexOfType(Class<?> entityType, final String type) {
|
||||||
|
|||||||
@@ -45,7 +45,7 @@ class SubscriptionUtils {
|
|||||||
* Wait for all {@link Subscription Subscriptions} to {@link Subscription#isActive() become active} but not longer
|
* Wait for all {@link Subscription Subscriptions} to {@link Subscription#isActive() become active} but not longer
|
||||||
* than {@link #DEFAULT_TIMEOUT}.
|
* than {@link #DEFAULT_TIMEOUT}.
|
||||||
*
|
*
|
||||||
* @param subscription
|
* @param subscriptions
|
||||||
* @throws InterruptedException
|
* @throws InterruptedException
|
||||||
*/
|
*/
|
||||||
static void awaitSubscriptions(Subscription... subscriptions) throws InterruptedException {
|
static void awaitSubscriptions(Subscription... subscriptions) throws InterruptedException {
|
||||||
@@ -131,7 +131,8 @@ class SubscriptionUtils {
|
|||||||
/**
|
/**
|
||||||
* {@link MessageListener} implementation collecting received {@link Message messages}.
|
* {@link MessageListener} implementation collecting received {@link Message messages}.
|
||||||
*
|
*
|
||||||
* @param <M>
|
* @param <S> source message type.
|
||||||
|
* @param <T> target message type.
|
||||||
*/
|
*/
|
||||||
static class CollectingMessageListener<S, T> implements MessageListener<S, T> {
|
static class CollectingMessageListener<S, T> implements MessageListener<S, T> {
|
||||||
|
|
||||||
|
|||||||
@@ -32,7 +32,7 @@ public abstract class Assertions extends org.assertj.core.api.Assertions {
|
|||||||
/**
|
/**
|
||||||
* Create assertion for {@link Document}.
|
* Create assertion for {@link Document}.
|
||||||
*
|
*
|
||||||
* @param actual the actual value.
|
* @param document the actual value.
|
||||||
* @return the created assertion object.
|
* @return the created assertion object.
|
||||||
*/
|
*/
|
||||||
public static DocumentAssert assertThat(Document document) {
|
public static DocumentAssert assertThat(Document document) {
|
||||||
|
|||||||
Reference in New Issue
Block a user