io.opencensus.common.Functions.throwAssertionError()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(9.6k)|赞(0)|评价(0)|浏览(87)

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

Functions.throwAssertionError介绍

[英]A Function that always ignores its argument and throws an AssertionError.
[中]总是忽略其参数并抛出断言错误的函数。

代码示例

代码示例来源：origin: census-instrumentation/opencensus-java

@Override
 public MutableAggregation apply(Sum arg) {
  return measure.match(
    CreateMutableSumDouble.INSTANCE,
    CreateMutableSumLong.INSTANCE,
    Functions.<MutableAggregation>throwAssertionError());
 }
},

代码示例来源：origin: census-instrumentation/opencensus-java

@Override
 public MutableAggregation apply(LastValue arg) {
  return measure.match(
    CreateMutableLastValueDouble.INSTANCE,
    CreateMutableLastValueLong.INSTANCE,
    Functions.<MutableAggregation>throwAssertionError());
 }
},

代码示例来源：origin: census-instrumentation/opencensus-java

static double getDoubleValueFromMeasurement(Measurement measurement) {
 return measurement.match(
   GET_VALUE_FROM_MEASUREMENT_DOUBLE,
   GET_VALUE_FROM_MEASUREMENT_LONG,
   Functions.<Double>throwAssertionError());
}

代码示例来源：origin: io.opencensus/opencensus-impl-core

@Override
 public MutableAggregation apply(LastValue arg) {
  return measure.match(
    CreateMutableLastValueDouble.INSTANCE,
    CreateMutableLastValueLong.INSTANCE,
    Functions.<MutableAggregation>throwAssertionError());
 }
},

代码示例来源：origin: io.opencensus/opencensus-impl-core

@Override
 public MutableAggregation apply(Sum arg) {
  return measure.match(
    CreateMutableSumDouble.INSTANCE,
    CreateMutableSumLong.INSTANCE,
    Functions.<MutableAggregation>throwAssertionError());
 }
},

代码示例来源：origin: io.opencensus/opencensus-impl-core

static double getDoubleValueFromMeasurement(Measurement measurement) {
 return measurement.match(
   GET_VALUE_FROM_MEASUREMENT_DOUBLE,
   GET_VALUE_FROM_MEASUREMENT_LONG,
   Functions.<Double>throwAssertionError());
}

代码示例来源：origin: census-instrumentation/opencensus-java

private static void checkWindow(
  View.AggregationWindow window, final AggregationWindowData windowData) {
 window.match(
   new Function<View.AggregationWindow.Cumulative, Void>() {
    @Override
    public Void apply(View.AggregationWindow.Cumulative arg) {
     throwIfWindowMismatch(
       windowData instanceof AggregationWindowData.CumulativeData, arg, windowData);
     return null;
    }
   },
   new Function<View.AggregationWindow.Interval, Void>() {
    @Override
    public Void apply(View.AggregationWindow.Interval arg) {
     throwIfWindowMismatch(
       windowData instanceof AggregationWindowData.IntervalData, arg, windowData);
     return null;
    }
   },
   Functions.</*@Nullable*/ Void>throwAssertionError());
}

代码示例来源：origin: census-instrumentation/opencensus-java

@Override
 public Void apply(Sum arg) {
  measure.match(
    new Function<MeasureDouble, Void>() {
     @Override
     public Void apply(MeasureDouble arg) {
      throwIfAggregationMismatch(
        aggregationData instanceof SumDataDouble, aggregation, aggregationData);
      return null;
     }
    },
    new Function<MeasureLong, Void>() {
     @Override
     public Void apply(MeasureLong arg) {
      throwIfAggregationMismatch(
        aggregationData instanceof SumDataLong, aggregation, aggregationData);
      return null;
     }
    },
    Functions.</*@Nullable*/ Void>throwAssertionError());
  return null;
 }
},

代码示例来源：origin: census-instrumentation/opencensus-java

private static void emitMeasureTableRow(Measure measure, PrintWriter out, Formatter formatter) {
 out.write("<tr>");
 formatter.format("<td><b>%s</b></td>", measure.getName());
 formatter.format("<td class=\"borderLL\">%s&nbsp;</td>", measure.getDescription());
 formatter.format("<td class=\"borderLL\">%s&nbsp;</td>", measure.getUnit());
 String measureType =
   measure.match(
     Functions.returnConstant("Double"),
     Functions.returnConstant("Long"),
     Functions.throwAssertionError());
 formatter.format("<td class=\"borderLL\">%s&nbsp;</td>", measureType);
 out.write("</tr>");
}

代码示例来源：origin: census-instrumentation/opencensus-java

private static DistributionValue.BucketOptions toBucketOptionsProto(
  Distribution.BucketOptions bucketOptions) {
 final DistributionValue.BucketOptions.Builder builder =
   DistributionValue.BucketOptions.newBuilder();
 bucketOptions.match(
   new Function<Distribution.BucketOptions.ExplicitOptions, Void>() {
    @Override
    public Void apply(Distribution.BucketOptions.ExplicitOptions arg) {
     builder.setExplicit(
       DistributionValue.BucketOptions.Explicit.newBuilder()
         .addAllBounds(arg.getBucketBoundaries())
         .build());
     return null;
    }
   },
   Functions.<Void>throwAssertionError());
 return builder.build();
}

代码示例来源：origin: census-instrumentation/opencensus-java

/**
 * Constructs a new {@link MutableViewData}.
 *
 * @param view the {@code View} linked with this {@code MutableViewData}.
 * @param start the start {@code Timestamp}.
 * @return a {@code MutableViewData}.
 */
static MutableViewData create(final View view, final Timestamp start) {
 return view.getWindow()
   .match(
     new CreateCumulative(view, start),
     new CreateInterval(view, start),
     Functions.<MutableViewData>throwAssertionError());
}

代码示例来源：origin: io.opencensus/opencensus-impl-core

/**
 * Constructs a new {@link MutableViewData}.
 *
 * @param view the {@code View} linked with this {@code MutableViewData}.
 * @param start the start {@code Timestamp}.
 * @return a {@code MutableViewData}.
 */
static MutableViewData create(final View view, final Timestamp start) {
 return view.getWindow()
   .match(
     new CreateCumulative(view, start),
     new CreateInterval(view, start),
     Functions.<MutableViewData>throwAssertionError());
}

代码示例来源：origin: com.impetus.fabric/fabric-jdbc-driver-shaded

@Override
@Nullable
public ViewData getView(View.Name name) {
 checkNotNull(name, "name");
 synchronized (registeredViews) {
  View view = registeredViews.get(name);
  if (view == null) {
   return null;
  } else {
   return ViewData.create(
     view,
     Collections.<List<TagValue>, AggregationData>emptyMap(),
     view.getWindow()
       .match(
         Functions.<AggregationWindowData>returnConstant(
           CumulativeData.create(ZERO_TIMESTAMP, ZERO_TIMESTAMP)),
         Functions.<AggregationWindowData>returnConstant(
           IntervalData.create(ZERO_TIMESTAMP)),
         Functions.<AggregationWindowData>throwAssertionError()));
  }
 }
}

代码示例来源：origin: census-instrumentation/opencensus-java

@Test
public void createAndGet_ExplicitBucketsEmptyBounds() {
 List<Double> bucketBounds = new ArrayList<Double>();
 BucketOptions bucketOptions = BucketOptions.explicitOptions(bucketBounds);
 final List<Double> actual = new ArrayList<Double>();
 bucketOptions.match(
   new Function<ExplicitOptions, Object>() {
    @Override
    public Object apply(ExplicitOptions arg) {
     actual.addAll(arg.getBucketBoundaries());
     return null;
    }
   },
   Functions.throwAssertionError());
 assertThat(actual).isEmpty();
}

代码示例来源：origin: census-instrumentation/opencensus-java

private static void assertContainsMeasure(OutputStream output, Measure measure) {
 assertThat(output.toString()).contains(measure.getName());
 assertThat(output.toString()).contains(measure.getDescription());
 assertThat(output.toString()).contains(measure.getUnit());
 String type =
   measure.match(
     Functions.returnConstant("Double"),
     Functions.returnConstant("Long"),
     Functions.throwAssertionError());
 assertThat(output.toString()).contains(type);
}

代码示例来源：origin: census-instrumentation/opencensus-java

@Test
public void createAndGet_ExplicitBuckets() {
 List<Double> bucketBounds = Arrays.asList(1.0, 2.0, 3.0);
 BucketOptions bucketOptions = BucketOptions.explicitOptions(bucketBounds);
 final List<Double> actual = new ArrayList<Double>();
 bucketOptions.match(
   new Function<ExplicitOptions, Object>() {
    @Override
    public Object apply(ExplicitOptions arg) {
     actual.addAll(arg.getBucketBoundaries());
     return null;
    }
   },
   Functions.throwAssertionError());
 assertThat(actual).containsExactlyElementsIn(bucketBounds).inOrder();
}

代码示例来源：origin: census-instrumentation/opencensus-java

@Test
public void testMatch() {
 List<Measure> measures =
   Arrays.asList(
     MeasureDouble.create("measure1", "description", "1"),
     MeasureLong.create("measure2", "description", "1"));
 List<String> outputs = Lists.newArrayList();
 for (Measure measure : measures) {
  outputs.add(
    measure.match(
      new Function<MeasureDouble, String>() {
       @Override
       public String apply(MeasureDouble arg) {
        return "double";
       }
      },
      new Function<MeasureLong, String>() {
       @Override
       public String apply(MeasureLong arg) {
        return "long";
       }
      },
      Functions.<String>throwAssertionError()));
 }
 assertThat(outputs).containsExactly("double", "long").inOrder();
}

代码示例来源：origin: census-instrumentation/opencensus-java

@Override
 public Object apply(Distribution arg) {
  actual.add(arg.getSum());
  actual.add(arg.getCount());
  actual.add(arg.getSumOfSquaredDeviations());
  arg.getBucketOptions()
    .match(
      new Function<ExplicitOptions, Object>() {
       @Override
       public Object apply(ExplicitOptions arg) {
        actual.addAll(arg.getBucketBoundaries());
        return null;
       }
      },
      Functions.throwAssertionError());
  for (Bucket bucket : arg.getBuckets()) {
   actual.add(bucket.getCount());
  }
  return null;
 }
},

代码示例来源：origin: census-instrumentation/opencensus-java

@Test
 public void testThrowAssertionError() {
  Function<Object, Void> f = Functions.throwAssertionError();
  thrown.handleAssertionErrors();
  thrown.expect(AssertionError.class);
  f.apply("ignored");
 }
}

代码示例来源：origin: census-instrumentation/opencensus-java

static ViewData createEmptyViewData(View view) {
 return ViewData.create(
   view,
   Collections.<List<TagValue>, AggregationData>emptyMap(),
   view.getWindow()
     .match(
       Functions.<AggregationWindowData>returnConstant(
         CumulativeData.create(ZERO_TIMESTAMP, ZERO_TIMESTAMP)),
       Functions.<AggregationWindowData>returnConstant(
         IntervalData.create(ZERO_TIMESTAMP)),
       Functions.<AggregationWindowData>throwAssertionError()));
}

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

Functions

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com