INNER CODE UNIT · Java

isAsyncContainer

scalecube/scalecube-services · services-api/src/main/java/io/scalecube/services/Reflect.java:169

  private static boolean isAsyncContainer(Type type) {
    Class<?> raw = toClass(type);

    if (raw == null) {
      return false;
    }

    return Publisher.class.isAssignableFrom(raw)
        || Stream.class.isAssignableFrom(raw)
        || Future.class.isAssignableFrom(raw);
  }

  public static Class<?> toClass(Type type) {
    if (type instanceof ParameterizedType pt) {
      return (Class<?>) pt.getRawType();
    }
    if (type instanceof Class<?> c) {
      return c;

View source record →