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

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

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

Util.classTag介绍

暂无

代码示例

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

/**
 * Same as <code>receiveN(n, remaining())</code>, but correctly treating the
 * timeFactor.
 */
public Object[] receiveN(int n) {
 return (Object[]) p.receiveN(n).toArray(Util.classTag(Object.class));
}

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

/**
 * Receive N messages in a row before the given deadline.
 */
public Object[] receiveN(int n, FiniteDuration max) {
 return (Object[]) p.receiveN(n, max).toArray(Util.classTag(Object.class));
}

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

@SuppressWarnings("unchecked")
public ReceiveWhile(Class<T> clazz, Duration max, Duration idle, int messages) {
 results = p.receiveWhile(max, idle, messages, new CachingPartialFunction<Object, T>() {
  public T match(Object msg) throws Exception {
   return ReceiveWhile.this.match(msg);
  }
 }).toArray(Util.classTag(clazz));
}

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

/** Same as <code>receiveN(n, remaining())</code>, but correctly treating the timeFactor. */
public Object[] receiveN(int n) {
 return (Object[]) p.receiveN(n).toArray(Util.classTag(Object.class));
}

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

/** Receive N messages in a row before the given deadline. */
public Object[] receiveN(int n, FiniteDuration max) {
 return (Object[]) p.receiveN(n, max).toArray(Util.classTag(Object.class));
}

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

/** Receive N messages in a row before the given deadline. */
public Object[] receiveN(int n, FiniteDuration max) {
 return (Object[]) p.receiveN(n, max).toArray(Util.classTag(Object.class));
}

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

/** Same as <code>receiveN(n, remaining())</code>, but correctly treating the timeFactor. */
public Object[] receiveN(int n) {
 return (Object[]) p.receiveN(n).toArray(Util.classTag(Object.class));
}

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

@SuppressWarnings("all")
public ReceiveWhile(Class<T> clazz, Duration max, Duration idle, int messages) {
 results =
   p.receiveWhile(
       max,
       idle,
       messages,
       new CachingPartialFunction<Object, T>() {
        public T match(Object msg) throws Exception {
         return ReceiveWhile.this.match(msg);
        }
       })
     .toArray(Util.classTag(clazz));
}

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

@SuppressWarnings("all")
public ReceiveWhile(Class<T> clazz, Duration max, Duration idle, int messages) {
 results =
   p.receiveWhile(
       max,
       idle,
       messages,
       new CachingPartialFunction<Object, T>() {
        public T match(Object msg) throws Exception {
         return ReceiveWhile.this.match(msg);
        }
       })
     .toArray(Util.classTag(clazz));
}

代码示例来源：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.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.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.10

/**
 * Same as <code>expectMsgAllOf(remaining(), 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));
}

代码示例来源：origin: com.data-artisans/flakka-testkit_2.10

/**
 * Receive N messages in a row before the given deadline.
 */
public Object[] receiveN(int n, FiniteDuration max) {
 return (Object[]) p.receiveN(n, max).toArray(Util.classTag(Object.class));
}

代码示例来源：origin: com.data-artisans/flakka-testkit_2.10

@SuppressWarnings("unchecked")
public ReceiveWhile(Class<T> clazz, Duration max, Duration idle, int messages) {
 results = p.receiveWhile(max, idle, messages, new CachingPartialFunction<Object, T>() {
  public T match(Object msg) throws Exception {
   return ReceiveWhile.this.match(msg);
  }
 }).toArray(Util.classTag(clazz));
}

代码示例来源：origin: com.data-artisans/flakka-testkit

@SuppressWarnings("unchecked")
public ReceiveWhile(Class<T> clazz, Duration max, Duration idle, int messages) {
 results = p.receiveWhile(max, idle, messages, new CachingPartialFunction<Object, T>() {
  public T match(Object msg) throws Exception {
   return ReceiveWhile.this.match(msg);
  }
 }).toArray(Util.classTag(clazz));
}

代码示例来源：origin: com.data-artisans/flakka-testkit

/**
 * 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.data-artisans/flakka-testkit

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

内容来源于网络，如有侵权，请联系作者删除！

Util

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com