software.amazon.awssdk.utils.IoUtils类的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(6.3k)|赞(0)|评价(0)|浏览(281)

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

IoUtils介绍

[英]Utilities for IO operations.
[中]

代码示例

代码示例来源：origin: software.amazon.awssdk/utils

  1. /**
  2.  * Closes the given Closeable quietly.
  3.  * @param maybeCloseable the given closeable
  4.  * @param log logger used to log any failure should the close fail
  5.  */
  6. public static void closeIfCloseable(Object maybeCloseable, Logger log) {
  7.   if (maybeCloseable instanceof AutoCloseable) {
  8.     IoUtils.closeQuietly((AutoCloseable) maybeCloseable, log);
  9.   }
  10. }

代码示例来源：origin: aws/aws-sdk-java-v2

  1. @Override
  2. public Void transform(Object response, AbortableInputStream inputStream) throws Exception {
  3.   this.captured = IoUtils.toUtf8String(inputStream);
  4.   return null;
  5. }

代码示例来源：origin: aws/aws-sdk-java-v2

  1. /**
  2.  * Reads and returns the rest of the given input stream as a string.
  3.  * Caller is responsible for closing the given input stream.
  4.  */
  5. public static String toUtf8String(InputStream is) throws IOException {
  6.   return new String(toByteArray(is), StandardCharsets.UTF_8);
  7. }

代码示例来源：origin: aws/aws-sdk-java-v2

  1. @Override
  2.   public void close() {
  3.     IoUtils.closeIfCloseable(parentCredentialsProvider, null);
  4.     IoUtils.closeQuietly(credentialsProvider, null);
  5.     IoUtils.closeQuietly(stsClient, null);
  6.   }
  7. }

代码示例来源：origin: aws/aws-sdk-java-v2

  1. return IoUtils.toUtf8String(inputStream);
  2. } else if (statusCode == HttpURLConnection.HTTP_NOT_FOUND) {
  3. IoUtils.closeQuietly(inputStream, log);

代码示例来源：origin: aws/aws-sdk-java-v2

  1. @Override
  2. public void close() {
  3.   // The delegate credentials provider may be closeable (eg. if it's an STS credentials provider). In this case, we should
  4.   // clean it up when this credentials provider is closed.
  5.   IoUtils.closeIfCloseable(credentialsProvider, null);
  6. }

代码示例来源：origin: software.amazon.awssdk/sdk-core

  1. /**
  2.  * Creates a response transformer that writes all response content to the given {@link OutputStream}. Note that
  3.  * the {@link OutputStream} is not closed or flushed after writing.
  4.  *
  5.  * @param outputStream Output stream to write data to.
  6.  * @param <ResponseT>  Type of unmarshalled response POJO.
  7.  * @return ResponseTransformer instance.
  8.  */
  9. static <ResponseT> ResponseTransformer<ResponseT, ResponseT> toOutputStream(OutputStream outputStream) {
  10.   return (resp, in) -> {
  11.     InterruptMonitor.checkInterrupted();
  12.     IoUtils.copy(in, outputStream);
  13.     return resp;
  14.   };
  15. }

代码示例来源：origin: software.amazon.awssdk/sts

  1. @Override
  2.   public void close() {
  3.     IoUtils.closeIfCloseable(parentCredentialsProvider, null);
  4.     IoUtils.closeQuietly(credentialsProvider, null);
  5.     IoUtils.closeQuietly(stsClient, null);
  6.   }
  7. }

代码示例来源：origin: software.amazon.awssdk/auth

  1. @Override
  2. public void close() {
  3.   // The delegate credentials provider may be closeable (eg. if it's an STS credentials provider). In this case, we should
  4.   // clean it up when this credentials provider is closed.
  5.   IoUtils.closeIfCloseable(credentialsProvider, null);
  6. }

代码示例来源：origin: aws/aws-sdk-java-v2

  1. @Override
  2. public Optional<RequestBody> modifyHttpContent(Context.ModifyHttpRequest context,
  3.                         ExecutionAttributes executionAttributes) {
  4.   if (!BLACKLIST_METHODS.contains(context.request().getClass()) && context.requestBody().isPresent()
  5.     && !context.httpRequest().firstMatchingHeader(CONTENT_MD5).isPresent()) {
  6.     try {
  7.       ByteArrayOutputStream baos = new ByteArrayOutputStream();
  8.       IoUtils.copy(context.requestBody().get().contentStreamProvider().newStream(), baos);
  9.       executionAttributes.putAttribute(CONTENT_MD5_ATTRIBUTE, Md5Utils.md5AsBase64(baos.toByteArray()));
  10.       return context.requestBody();
  11.     } catch (IOException e) {
  12.       throw new UncheckedIOException(e);
  13.     }
  14.   }
  15.   return context.requestBody();
  16. }

代码示例来源：origin: aws/aws-sdk-java-v2

  1. /**
  2.  * Closes the given Closeable quietly.
  3.  * @param maybeCloseable the given closeable
  4.  * @param log logger used to log any failure should the close fail
  5.  */
  6. public static void closeIfCloseable(Object maybeCloseable, Logger log) {
  7.   if (maybeCloseable instanceof AutoCloseable) {
  8.     IoUtils.closeQuietly((AutoCloseable) maybeCloseable, log);
  9.   }
  10. }

代码示例来源：origin: software.amazon.awssdk/protocol-tests-core

  1. @Override
  2. public Void transform(Object response, AbortableInputStream inputStream) throws Exception {
  3.   this.captured = IoUtils.toUtf8String(inputStream);
  4.   return null;
  5. }

代码示例来源：origin: software.amazon.awssdk/utils

  1. /**
  2.  * Reads and returns the rest of the given input stream as a string.
  3.  * Caller is responsible for closing the given input stream.
  4.  */
  5. public static String toUtf8String(InputStream is) throws IOException {
  6.   return new String(toByteArray(is), StandardCharsets.UTF_8);
  7. }

代码示例来源：origin: aws/aws-sdk-java-v2

  1. @Override
  2. public void close() {
  3.   credentialsProviders.forEach(c -> IoUtils.closeIfCloseable(c, null));
  4. }

代码示例来源：origin: aws/aws-sdk-java-v2

  1. @Override
  2. public HttpExecuteResponse call() throws IOException {
  3.   connection.connect();
  4.   request.contentStreamProvider().ifPresent(provider ->
  5.       invokeSafely(() -> IoUtils.copy(provider.newStream(), connection.getOutputStream())));
  6.   int responseCode = connection.getResponseCode();
  7.   boolean isErrorResponse = HttpStatusFamily.of(responseCode).isOneOf(CLIENT_ERROR, SERVER_ERROR);
  8.   InputStream content = !isErrorResponse ? connection.getInputStream() : connection.getErrorStream();
  9.   AbortableInputStream responseBody = content != null ?
  10.                     AbortableInputStream.create(content) : null;
  11.   return HttpExecuteResponse.builder()
  12.                .response(SdkHttpResponse.builder()
  13.                           .statusCode(responseCode)
  14.                           .statusText(connection.getResponseMessage())
  15.                           // TODO: Don't ignore abort?
  16.                           .headers(extractHeaders(connection))
  17.                           .build())
  18.                .responseBody(responseBody)
  19.                .build();
  20. }

代码示例来源：origin: aws/aws-sdk-java-v2

  1. public static void closeQuietly(Closeable closeable) {
  2.     IoUtils.closeQuietly(closeable, null);
  3.   }
  4. }

代码示例来源：origin: aws/aws-sdk-java-v2

  1. /**
  2.  * Reads a system resource fully into a String
  3.  *
  4.  * @param location
  5.  *            Relative or absolute location of system resource.
  6.  * @return String contents of resource file
  7.  * @throws RuntimeException
  8.  *             if any error occurs
  9.  */
  10. protected String getResourceAsString(Class<?> clazz, String location) {
  11.   try (InputStream resourceStream = clazz.getResourceAsStream(location)) {
  12.     return IoUtils.toUtf8String(resourceStream);
  13.   } catch (IOException e) {
  14.     throw new RuntimeException(e);
  15.   }
  16. }

代码示例来源：origin: software.amazon.awssdk/sdk-core

  1. /**
  2.  * Create {@link SdkBytes} from an input stream. This will read all of the remaining contents of the stream, but will not
  3.  * close it.
  4.  */
  5. public static SdkBytes fromInputStream(InputStream inputStream) {
  6.   Validate.paramNotNull(inputStream, "inputStream");
  7.   return new SdkBytes(invokeSafely(() -> IoUtils.toByteArray(inputStream)));
  8. }

代码示例来源：origin: software.amazon.awssdk/auth

  1. @Override
  2. public void close() {
  3.   credentialsProviders.forEach(c -> IoUtils.closeIfCloseable(c, null));
  4. }

代码示例来源：origin: software.amazon.awssdk/codegen-lite

  1. public static void closeQuietly(Closeable closeable) {
  2.     IoUtils.closeQuietly(closeable, null);
  3.   }
  4. }

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

IOUtils

相关文章

    查看更多

    热门标签

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

    最新文章

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