class="kw">package com.hypixel.hytale.metrics;

class="kw">import com.hypixel.hytale.codec.Codec;
class="kw">import com.hypixel.hytale.codec.ExtraInfo;
class="kw">import java.util.concurrent.CompletableFuture;
class="kw">import java.util.concurrent.Executor;
class="kw">import java.util.function.Function;
class="kw">import javax.annotation.Nonnull;
class="kw">import org.bson.BsonValue;

class="kw">public class ExecutorMetricsRegistry<T class="kw">extends ExecutorMetricsRegistry.ExecutorMetric> class="kw">extends MetricsRegistry<T> {
   class="kw">public ExecutorMetricsRegistry() {
   }

   class="kw">public BsonValue encode(@Nonnull T var1, ExtraInfo var2) {
      class="kw">return var1.isInThread() ? super.encode(var1, var2) : CompletableFuture.<BsonValue>supplyAsync(() -> super.encode(var1, var2), var1).join();
   }

   class="kw">public <R class="kw">extends MetricProvider> ExecutorMetricsRegistry<T> register(String var1, @Nonnull Function<T, R> var2) {
      class="kw">return (ExecutorMetricsRegistry<T>)super.register(var1, var2);
   }

   class="kw">public <R> ExecutorMetricsRegistry<T> register(String var1, Function<T, R> var2, Codec<R> var3) {
      class="kw">return (ExecutorMetricsRegistry<T>)super.register(var1, var2, var3);
   }

   class="kw">public ExecutorMetricsRegistry<T> register(String var1, MetricsRegistry<Void> var2) {
      class="kw">return (ExecutorMetricsRegistry<T>)super.register(var1, var2);
   }

   class="kw">public <R> ExecutorMetricsRegistry<T> register(String var1, Function<T, R> var2, Function<R, MetricsRegistry<R>> var3) {
      class="kw">return (ExecutorMetricsRegistry<T>)super.register(var1, var2, var3);
   }

   class="kw">public class="kw">interface ExecutorMetric class="kw">extends Executor {
      boolean isInThread();
   }
}