akka.util.ByteString.iterator()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(7.7k)|赞(0)|评价(0)|浏览(124)

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

ByteString.iterator介绍

暂无

代码示例

代码示例来源：origin: com.typesafe.play/play_2.11

@Override
  protected JsonNode parse(Http.RequestHeader request, ByteString bytes) throws Exception {
    return play.libs.Json.parse(bytes.iterator().asInputStream());
  }
}

代码示例来源：origin: com.typesafe.play/play_2.12

@Override
  protected JsonNode parse(Http.RequestHeader request, ByteString bytes) throws Exception {
    return play.libs.Json.parse(bytes.iterator().asInputStream());
  }
}

代码示例来源：origin: com.typesafe.play/play

@Override
  protected JsonNode parse(Http.RequestHeader request, ByteString bytes) throws Exception {
    return play.libs.Json.parse(bytes.iterator().asInputStream());
  }
}

代码示例来源：origin: com.typesafe.play/play

@Override
  protected Document parse(Http.RequestHeader request, ByteString bytes) throws Exception {
    return XML.fromInputStream(bytes.iterator().asInputStream(), request.charset().orElse(null));
  }
}

代码示例来源：origin: com.typesafe.play/play_2.12

@Override
  protected Document parse(Http.RequestHeader request, ByteString bytes) throws Exception {
    return XML.fromInputStream(bytes.iterator().asInputStream(), request.charset().orElse(null));
  }
}

代码示例来源：origin: com.typesafe.play/play_2.11

@Override
  protected Document parse(Http.RequestHeader request, ByteString bytes) throws Exception {
    return XML.fromInputStream(bytes.iterator().asInputStream(), request.charset().orElse(null));
  }
}

代码示例来源：origin: com.typesafe.play/play_2.12

/**
 * Acceptor for JSON WebSockets.
 *
 * @param in The class of the incoming messages, used to decode them from the JSON.
 * @param <In> The websocket's input type (what it receives from clients)
 * @param <Out> The websocket's output type (what it writes to clients)
 * @return The WebSocket acceptor.
 */
public static <In, Out> MappedWebSocketAcceptor<In, Out> json(Class<In> in) {
  return new MappedWebSocketAcceptor<>(Scala.partialFunction(message -> {
    try {
      if (message instanceof Message.Binary) {
        return F.Either.Left(play.libs.Json.mapper().readValue(((Message.Binary) message).data().iterator().asInputStream(), in));
      } else if (message instanceof Message.Text) {
        return F.Either.Left(play.libs.Json.mapper().readValue(((Message.Text) message).data(), in));
      }
    } catch (Exception e) {
      return F.Either.Right(new Message.Close(CloseCodes.Unacceptable(), e.getMessage()));
    }
    throw Scala.noMatch();
  }), outMessage -> {
    try {
      return new Message.Text(play.libs.Json.mapper().writeValueAsString(outMessage));
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  });
}

代码示例来源：origin: com.typesafe.play/play_2.11

/**
 * Acceptor for JSON WebSockets.
 *
 * @param in The class of the incoming messages, used to decode them from the JSON.
 * @param <In> The websocket's input type (what it receives from clients)
 * @param <Out> The websocket's output type (what it writes to clients)
 * @return The WebSocket acceptor.
 */
public static <In, Out> MappedWebSocketAcceptor<In, Out> json(Class<In> in) {
  return new MappedWebSocketAcceptor<>(Scala.partialFunction(message -> {
    try {
      if (message instanceof Message.Binary) {
        return F.Either.Left(play.libs.Json.mapper().readValue(((Message.Binary) message).data().iterator().asInputStream(), in));
      } else if (message instanceof Message.Text) {
        return F.Either.Left(play.libs.Json.mapper().readValue(((Message.Text) message).data(), in));
      }
    } catch (Exception e) {
      return F.Either.Right(new Message.Close(CloseCodes.Unacceptable(), e.getMessage()));
    }
    throw Scala.noMatch();
  }), outMessage -> {
    try {
      return new Message.Text(play.libs.Json.mapper().writeValueAsString(outMessage));
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  });
}

代码示例来源：origin: com.typesafe.play/play

/**
 * Acceptor for JSON WebSockets.
 *
 * @param in The class of the incoming messages, used to decode them from the JSON.
 * @param <In> The websocket's input type (what it receives from clients)
 * @param <Out> The websocket's output type (what it writes to clients)
 * @return The WebSocket acceptor.
 */
public static <In, Out> MappedWebSocketAcceptor<In, Out> json(Class<In> in) {
  return new MappedWebSocketAcceptor<>(Scala.partialFunction(message -> {
    try {
      if (message instanceof Message.Binary) {
        return F.Either.Left(play.libs.Json.mapper().readValue(((Message.Binary) message).data().iterator().asInputStream(), in));
      } else if (message instanceof Message.Text) {
        return F.Either.Left(play.libs.Json.mapper().readValue(((Message.Text) message).data(), in));
      }
    } catch (Exception e) {
      return F.Either.Right(new Message.Close(CloseCodes.Unacceptable(), e.getMessage()));
    }
    throw Scala.noMatch();
  }), outMessage -> {
    try {
      return new Message.Text(play.libs.Json.mapper().writeValueAsString(outMessage));
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  });
}

代码示例来源：origin: org.elder.sourcerer/sourcerer-eventstore

private T fromEsDataContent(final Content data) {
  try {
    T rawEvent = objectMapper
        .readerFor(eventClass)
        .readValue(data.value().iterator().asInputStream());
    return normalizeEvent(rawEvent);
  } catch (IOException ex) {
    throw new RetriableEventReadException("Internal error reading events", ex);
  }
}

代码示例来源：origin: elder-oss/sourcerer

private T fromEsDataContent(final Content data) {
  try {
    T rawEvent = objectMapper
        .readerFor(eventClass)
        .readValue(data.value().iterator().asInputStream());
    return normalizeEvent(rawEvent);
  } catch (IOException ex) {
    throw new RetriableEventReadException("Internal error reading events", ex);
  }
}

代码示例来源：origin: elder-oss/sourcerer

@SuppressWarnings("unchecked")
private ImmutableMap<String, String> fromEsMetadata(final Content metadata) {
  if (metadata == null
      || metadata.contentType() != ContentType.json()
      || metadata.value().size() == 0) {
    return ImmutableMap.of();
  }
  try {
    return ImmutableMap.copyOf((Map) objectMapper
        .readerFor(new TypeReference<Map<String, String>>() {
        })
        .readValue(metadata.value().iterator().asInputStream()));
  } catch (IOException ex) {
    throw new RetriableEventReadException("Internal error reading events", ex);
  }
}

代码示例来源：origin: org.elder.sourcerer/sourcerer-eventstore

@SuppressWarnings("unchecked")
private ImmutableMap<String, String> fromEsMetadata(final Content metadata) {
  if (metadata == null
      || metadata.contentType() != ContentType.json()
      || metadata.value().size() == 0) {
    return ImmutableMap.of();
  }
  try {
    return ImmutableMap.copyOf((Map) objectMapper
        .readerFor(new TypeReference<Map<String, String>>() {
        })
        .readValue(metadata.value().iterator().asInputStream()));
  } catch (IOException ex) {
    throw new RetriableEventReadException("Internal error reading events", ex);
  }
}

代码示例来源：origin: com.github.rmannibucau/playx-servlet

@Override
  public Accumulator<ByteString, Result> apply(final Http.RequestHeader requestHeader) {
    return state.getServletContext().findMatchingServlet(requestHeader).map(servlet -> {
      final long length = requestHeader.getHeaders().get("Content-Length").map(Long::parseLong)
          .orElse(Long.MAX_VALUE);
      final BodyParser.Bytes slurper = new BodyParser.Bytes(length, state.getHttpErrorHandler());
      return slurper.apply(requestHeader).mapFuture(
          resultOrBytes -> resultOrBytes.left.map(CompletableFuture::completedFuture).orElseGet(() -> {
            return state.getServletContext()
                .executeInvoke(servlet, requestHeader,
                    resultOrBytes.right.get().iterator().asInputStream(), servlet.getServletPath())
                .toCompletableFuture();
          }), state.getServletContext().getDefaultExecutor());
    }).orElseGet(() -> next.apply(requestHeader));
  }
};

代码示例来源：origin: com.lightbend.lagom/lagom-javadsl-jackson

@Override
  public Throwable deserialize(RawExceptionMessage message) {
    ExceptionMessage exceptionMessage;
    try {
      exceptionMessage = objectMapper.readValue(message.message().iterator().asInputStream(), ExceptionMessage.class);
    } catch (Exception e) {
      exceptionMessage = new ExceptionMessage("UndeserializableException", message.message().utf8String());
    }
    return TransportException.fromCodeAndMessage(message.errorCode(), exceptionMessage);
  }
}

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

ByteString

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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