akka.japi.Util.immutableSeq()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(6.9k)|赞(0)|评价(0)|浏览(71)

本文整理了Java中akka.japi.Util.immutableSeq()方法的一些代码示例,展示了Util.immutableSeq()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Util.immutableSeq()方法的具体详情如下:
包路径:akka.japi.Util
类名称:Util
方法名:immutableSeq

Util.immutableSeq介绍

暂无

代码示例

代码示例来源:origin: com.typesafe.akka/akka-actor_2.11

@SafeVarargs
 public static <T> Seq<T> seq(T... ts) {
  return Util.immutableSeq(ts);
 }
}

代码示例来源:origin: com.typesafe.akka/akka-actor_2.12

@SafeVarargs
 public static <T> Seq<T> seq(T... ts) {
  return Util.immutableSeq(ts);
 }
}

代码示例来源:origin: com.typesafe.akka/akka-actor

@SafeVarargs
 public static <T> Seq<T> seq(T... ts) {
  return Util.immutableSeq(ts);
 }
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.10

/**
 * Same as <code>expectMsgAnyOf(remaining(), obj...)</code>, but correctly
 * treating the timeFactor.
 */
public Object expectMsgAnyOf(Object... msgs) {
 return p.expectMsgAnyOf(Util.immutableSeq(msgs));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.12

/**
 * Same as <code>expectMsgAnyOf(remainingOrDefault(), obj...)</code>, but correctly treating the
 * timeFactor.
 */
public Object expectMsgAnyOf(Object... msgs) {
 return p.expectMsgAnyOf(Util.immutableSeq(msgs));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.11

/**
 * Receive one message from the test actor and assert that it equals one of the given objects.
 * Wait time is bounded by the given duration, with an AssertionFailure being thrown in case of
 * timeout.
 *
 * @return the received object
 */
public Object expectMsgAnyOf(FiniteDuration max, Object... msgs) {
 return p.expectMsgAnyOf(max, Util.immutableSeq(msgs));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.11

/**
 * Receive one message from the test actor and assert that it conforms to one of the given
 * classes. Wait time is bounded by the given duration, with an AssertionFailure being thrown in
 * case of timeout.
 *
 * @return the received object
 */
public Object expectMsgAnyClassOf(FiniteDuration max, Class<?>... classes) {
 return p.expectMsgAnyClassOf(max, Util.immutableSeq(classes));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.11

/**
 * Same as <code>expectMsgAnyClassOf(remainingOrDefault(), obj...)</code>, but correctly treating
 * the timeFactor.
 */
@SuppressWarnings("unchecked")
public <T> T expectMsgAnyClassOf(Class<? extends T>... classes) {
 final Object result = p.expectMsgAnyClassOf(Util.immutableSeq(classes));
 return (T) result;
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.10

/**
 * Receive one message from the test actor and assert that it conforms to one
 * of the given classes. Wait time is bounded by the given duration, with an
 * AssertionFailure being thrown in case of timeout.
 * 
 * @return the received object
 */
public Object expectMsgAnyClassOf(FiniteDuration max, Class<?>... classes) {
 return p.expectMsgAnyClassOf(max, Util.immutableSeq(classes));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.10

/**
 * Receive one message from the test actor and assert that it equals one of
 * the given objects. Wait time is bounded by the given duration, with an
 * AssertionFailure being thrown in case of timeout.
 * 
 * @return the received object
 */
public Object expectMsgAnyOf(FiniteDuration max, Object... msgs) {
 return p.expectMsgAnyOf(max, Util.immutableSeq(msgs));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.12

/**
 * Same as <code>expectMsgAnyClassOf(remainingOrDefault(), obj...)</code>, but correctly treating
 * the timeFactor.
 */
@SuppressWarnings("unchecked")
public <T> T expectMsgAnyClassOf(Class<? extends T>... classes) {
 final Object result = p.expectMsgAnyClassOf(Util.immutableSeq(classes));
 return (T) result;
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.11

/**
 * Same as <code>expectMsgAnyOf(remainingOrDefault(), obj...)</code>, but correctly treating the
 * timeFactor.
 */
public Object expectMsgAnyOf(Object... msgs) {
 return p.expectMsgAnyOf(Util.immutableSeq(msgs));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.10

/**
 * Same as <code>expectMsgAnyClassOf(remaining(), obj...)</code>, but
 * correctly treating the timeFactor.
 */
@SuppressWarnings("unchecked")
public <T> T expectMsgAnyClassOf(Class<? extends T>... classes) {
 final Object result = p.expectMsgAnyClassOf(Util.immutableSeq(classes));
 return (T) result;
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.12

/**
 * Receive one message from the test actor and assert that it equals one of the given objects.
 * Wait time is bounded by the given duration, with an AssertionFailure being thrown in case of
 * timeout.
 *
 * @return the received object
 */
public Object expectMsgAnyOf(FiniteDuration max, Object... msgs) {
 return p.expectMsgAnyOf(max, Util.immutableSeq(msgs));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.12

/**
 * Receive one message from the test actor and assert that it conforms to one of the given
 * classes. Wait time is bounded by the given duration, with an AssertionFailure being thrown in
 * case of timeout.
 *
 * @return the received object
 */
public Object expectMsgAnyClassOf(FiniteDuration max, Class<?>... classes) {
 return p.expectMsgAnyClassOf(max, Util.immutableSeq(classes));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.10

/**
 * Receive a number of messages from the test actor matching the given number
 * of objects and assert that for each given object one is received which
 * equals it and vice versa. This construct is useful when the order in which
 * the objects are received is not fixed. Wait time is bounded by the given
 * duration, with an AssertionFailure being thrown in case of timeout.
 */
public Object[] expectMsgAllOf(FiniteDuration max, Object... msgs) {
 return (Object[]) p.expectMsgAllOf(max, Util.immutableSeq(msgs)).toArray(Util.classTag(Object.class));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.12

/**
 * Same as <code>expectMsgAllOf(remainingOrDefault(), obj...)</code>, but correctly treating the
 * timeFactor.
 */
public Object[] expectMsgAllOf(Object... msgs) {
 return (Object[])
   p.expectMsgAllOf(Util.immutableSeq(msgs)).toArray(Util.classTag(Object.class));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.11

/**
 * Same as <code>expectMsgAllOf(remainingOrDefault(), obj...)</code>, but correctly treating the
 * timeFactor.
 */
public Object[] expectMsgAllOf(Object... msgs) {
 return (Object[])
   p.expectMsgAllOf(Util.immutableSeq(msgs)).toArray(Util.classTag(Object.class));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.11

/**
 * Receive a number of messages from the test actor matching the given number of objects and
 * assert that for each given object one is received which equals it and vice versa. This
 * construct is useful when the order in which the objects are received is not fixed. Wait time is
 * bounded by the given duration, with an AssertionFailure being thrown in case of timeout.
 */
public Object[] expectMsgAllOf(FiniteDuration max, Object... msgs) {
 return (Object[])
   p.expectMsgAllOf(max, Util.immutableSeq(msgs)).toArray(Util.classTag(Object.class));
}

代码示例来源:origin: com.typesafe.akka/akka-testkit_2.12

/**
 * Receive a number of messages from the test actor matching the given number of objects and
 * assert that for each given object one is received which equals it and vice versa. This
 * construct is useful when the order in which the objects are received is not fixed. Wait time is
 * bounded by the given duration, with an AssertionFailure being thrown in case of timeout.
 */
public Object[] expectMsgAllOf(FiniteDuration max, Object... msgs) {
 return (Object[])
   p.expectMsgAllOf(max, Util.immutableSeq(msgs)).toArray(Util.classTag(Object.class));
}

相关文章

微信公众号

最新文章

更多