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

AsyncFuture.transform介绍

暂无

代码示例

代码示例来源：origin: spotify/ffwd

@Override
public AsyncFuture<Void> start() {
  return servers
    .bind(log, protocol, server, policy)
    .transform(new Transform<ProtocolConnection, Void>() {
      @Override
      public Void transform(ProtocolConnection c) throws Exception {
        if (!connection.compareAndSet(null, c)) {
          c.stop();
        }
        return null;
      }
    });
}

代码示例来源：origin: spotify/ffwd

@Override
public AsyncFuture<Void> start() {
  return servers
    .bind(log, protocol, server, retry)
    .transform(new Transform<ProtocolConnection, Void>() {
      @Override
      public Void transform(ProtocolConnection c) throws Exception {
        if (!connection.compareAndSet(null, c)) {
          c.stop();
        }
        return null;
      }
    });
}

代码示例来源：origin: spotify/ffwd

@Override
public AsyncFuture<Void> start() {
  return servers
    .bind(log, protocol, server, policy)
    .transform(new Transform<ProtocolConnection, Void>() {
      @Override
      public Void transform(ProtocolConnection c) throws Exception {
        if (!connection.compareAndSet(null, c)) {
          c.stop();
        }
        return null;
      }
    });
}

代码示例来源：origin: spotify/ffwd

@Override
public AsyncFuture<Void> start() {
  return servers
    .bind(log, protocol, server, policy)
    .transform(new Transform<ProtocolConnection, Void>() {
      @Override
      public Void transform(ProtocolConnection c) throws Exception {
        if (!connection.compareAndSet(null, c)) {
          c.stop();
        }
        return null;
      }
    });
}

代码示例来源：origin: spotify/ffwd

@Override
public AsyncFuture<Void> start() {
  return servers
    .bind(log, protocol, server, policy)
    .transform(new Transform<ProtocolConnection, Void>() {
      @Override
      public Void transform(ProtocolConnection c) throws Exception {
        if (!connection.compareAndSet(null, c)) {
          c.stop();
        }
        return null;
      }
    });
}

代码示例来源：origin: com.spotify.ffwd/ffwd-api

@Override
public AsyncFuture<Void> start() {
  return servers
    .bind(log, protocol, server, retry)
    .transform(new Transform<ProtocolConnection, Void>() {
      @Override
      public Void transform(ProtocolConnection c) throws Exception {
        if (!connection.compareAndSet(null, c)) {
          c.stop();
        }
        return null;
      }
    });
}

代码示例来源：origin: com.spotify.ffwd/ffwd-api

@Override
public AsyncFuture<Void> start() {
  return sink.start().transform((Transform<Void, Void>) result -> {
    scheduleNext();
    return null;
  });
}

代码示例来源：origin: spotify/ffwd

@Override
public AsyncFuture<Void> start() {
  return sink.start().transform((Transform<Void, Void>) result -> {
    scheduleNext();
    return null;
  });
}