本文整理了Java中akka.japi.Util.immutableSeq()
方法的一些代码示例,展示了Util.immutableSeq()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Util.immutableSeq()
方法的具体详情如下:
包路径:akka.japi.Util
类名称: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));
}
内容来源于网络,如有侵权,请联系作者删除!