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

Future.value介绍

暂无

代码示例

代码示例来源：origin: twitter/distributedlog

public Future<Long> apply(final LogRecordWithDLSN endRecord) {
    if (null != endRecord) {
      return asyncGetLogRecordCount(ledger, beginDLSN, endRecord.getLastPositionWithinLogSegment() /* end position */);
    } else {
      return Future.value((long) 0);
    }
  }
});

代码示例来源：origin: twitter/distributedlog

@Override
  public Future<Void> setAcceptNewStream(boolean enabled) {
    return Future.value(null);
  }
}

代码示例来源：origin: twitter/distributedlog

@Override
  public Future<Boolean> issueSpeculativeRequest() {
    return Future.value(!complete.get() && null != sendNextWrite());
  }
}

代码示例来源：origin: twitter/distributedlog

@Override
  public Future<byte[]> apply(ThriftClientRequest request) {
    return Future.value(request.message);
  }
}

代码示例来源：origin: twitter/distributedlog

@Override
  public Future<Void> asyncClose() {
    if (ownAllocator) {
      return this.allocator.asyncClose();
    } else {
      return Future.value(null);
    }
  }
}

代码示例来源：origin: twitter/distributedlog

@Override
  public Future<ServerInfo> handshakeWithClientInfo(ClientInfo clientInfo) {
    return Future.value(serverInfo);
  }
}

代码示例来源：origin: twitter/distributedlog

@Override
  public Future<Versioned<byte[]>> apply(Versioned<byte[]> result) {
    if (null != result && null != result.getVersion() && null != result.getValue()) {
      return Future.value(result);
    }
    return createAllocationData(allocatePath, zkc);
  }
});

代码示例来源：origin: twitter/distributedlog

@Override
  public Object answer(InvocationOnMock invocation) throws Throwable {
    try {
      return Future.value(callCount.incrementAndGet() < 3);
    } finally {
      latch.countDown();
    }
  }
}).when(executor).issueSpeculativeRequest();

代码示例来源：origin: twitter/distributedlog

@Override
public Future<WriteResponse> heartbeatWithOptions(String stream,
                         WriteContext ctx,
                         HeartbeatOptions options) {
  return Future.value(new WriteResponse());
}

代码示例来源：origin: twitter/distributedlog

@Override
public Future<WriteResponse> release(String stream,
                   WriteContext ctx) {
  return Future.value(new WriteResponse());
}

代码示例来源：origin: twitter/distributedlog

@Override
  public Object answer(InvocationOnMock invocation) throws Throwable {
    Object[] arguments = invocation.getArguments();
    String stream = (String) arguments[0];
    if (stream.equals(secondStream)) {
      return Future.value(dlsn);
    } else {
      return new Promise<DLSN>();
    }
  }
}).when(client).writeRecordSet((String) any(), (LogRecordSetBuffer) any());

代码示例来源：origin: twitter/distributedlog

@Override
  public Future<Long> apply(Integer transmitRc) {
    if (BKException.Code.OK == transmitRc) {
      return Future.value(getLastTxIdAcknowledged());
    } else {
      return Future.exception(new BKTransmitException("Failed to transmit entry", transmitRc));
    }
  }
};

代码示例来源：origin: twitter/distributedlog

@Override
public Future<WriteResponse> truncate(String stream,
                   String dlsn,
                   WriteContext ctx) {
  return Future.value(new WriteResponse());
}

代码示例来源：origin: twitter/distributedlog

public Future<ServerInfo> apply(byte[] __buffer__) {
  TMemoryInputTransport __memoryTransport__ = new TMemoryInputTransport(__buffer__);
  TProtocol __prot__ = ServiceToClient.this.protocolFactory.getProtocol(__memoryTransport__);
  try {
   return Future.value((new Client(__prot__)).recv_handshakeWithClientInfo());
  } catch (Exception e) {
   return Future.exception(e);
  }
 }
});

代码示例来源：origin: twitter/distributedlog

public Future<WriteResponse> apply(byte[] __buffer__) {
  TMemoryInputTransport __memoryTransport__ = new TMemoryInputTransport(__buffer__);
  TProtocol __prot__ = ServiceToClient.this.protocolFactory.getProtocol(__memoryTransport__);
  try {
   return Future.value((new Client(__prot__)).recv_write());
  } catch (Exception e) {
   return Future.exception(e);
  }
 }
});

代码示例来源：origin: twitter/distributedlog

public Future<BulkWriteResponse> apply(byte[] __buffer__) {
  TMemoryInputTransport __memoryTransport__ = new TMemoryInputTransport(__buffer__);
  TProtocol __prot__ = ServiceToClient.this.protocolFactory.getProtocol(__memoryTransport__);
  try {
   return Future.value((new Client(__prot__)).recv_writeBulkWithContext());
  } catch (Exception e) {
   return Future.exception(e);
  }
 }
});

代码示例来源：origin: twitter/distributedlog

public Future<WriteResponse> apply(byte[] __buffer__) {
  TMemoryInputTransport __memoryTransport__ = new TMemoryInputTransport(__buffer__);
  TProtocol __prot__ = ServiceToClient.this.protocolFactory.getProtocol(__memoryTransport__);
  try {
   return Future.value((new Client(__prot__)).recv_delete());
  } catch (Exception e) {
   return Future.exception(e);
  }
 }
});

代码示例来源：origin: twitter/distributedlog

public Future<WriteResponse> apply(byte[] __buffer__) {
  TMemoryInputTransport __memoryTransport__ = new TMemoryInputTransport(__buffer__);
  TProtocol __prot__ = ServiceToClient.this.protocolFactory.getProtocol(__memoryTransport__);
  try {
   return Future.value((new Client(__prot__)).recv_writeWithContext());
  } catch (Exception e) {
   return Future.exception(e);
  }
 }
});

代码示例来源：origin: twitter/distributedlog

public Future<WriteResponse> apply(byte[] __buffer__) {
  TMemoryInputTransport __memoryTransport__ = new TMemoryInputTransport(__buffer__);
  TProtocol __prot__ = ServiceToClient.this.protocolFactory.getProtocol(__memoryTransport__);
  try {
   return Future.value((new Client(__prot__)).recv_release());
  } catch (Exception e) {
   return Future.exception(e);
  }
 }
});

代码示例来源：origin: twitter/distributedlog

public Future<WriteResponse> apply(byte[] __buffer__) {
  TMemoryInputTransport __memoryTransport__ = new TMemoryInputTransport(__buffer__);
  TProtocol __prot__ = ServiceToClient.this.protocolFactory.getProtocol(__memoryTransport__);
  try {
   return Future.value((new Client(__prot__)).recv_create());
  } catch (Exception e) {
   return Future.exception(e);
  }
 }
});