protocols/src/test/java/eu/internetofus/common/protocols/AbstractProtocolITC.java
/**
   * Check that is send the specified task status.
   *
   * @param vertx       event bus to use.
   * @param testContext context to do the test.
   * @param userId      identifier of the user.
   * @param checkState  this predicate is true when the community user state has
   *                    the expected values.
   *
   * @return the future community user state.
   *
   * @see #waitUntilTask(Vertx, VertxTestContext, Predicate)
   */
Check that is send the specified task status.
@param vertx       event bus to use.
@param testContext context to do the test.
@param userId      identifier of the user.
@param checkState  this predicate is true when the community user state has
the expected values.

@return the future community user state.


Check that is send the specified task status . @param vertx event bus to use . @param testContext context to do the test . @param userId identifier of the user . @param checkState this predicate is true when the community user state has the expected values . @return the future community user state .
protected Future<State> waitUntilCommunityUserState(@NotNull final Vertx vertx,
      @NotNull final VertxTestContext testContext, @NotNull final String userId,
      @NotNull final Predicate<State> checkState) {
    return this.waitUntil(vertx, testContext,
        () -> WeNetInteractionProtocolEngine.createProxy(vertx).retrieveCommunityUserState(this.community.id, userId),
        checkState);
  }
protected Future < State > waitUntilCommunityUserState ( @ NotNull final Vertx vertx , @ NotNull final VertxTestContext testContext , @ NotNull final String userId , @ NotNull final Predicate < State > checkState ) { return this . waitUntil ( vertx , testContext , ( ) -> WeNetInteractionProtocolEngine . createProxy ( vertx ) . retrieveCommunityUserState ( this . community . id , userId ) , checkState ) ; }
Check that is send the specified task status.
Check that is send the specified task status .