}
try {
- final var queryString = httpExchange.getRequestURI().getQuery();
+ final var queryString = httpExchange.getRequestURI().getRawQuery();
final var query = queryString == null ? Map.<String, String>of() : Util.getQueryMap(queryString);
List<Manager> managers = getManagerFromQuery(query);
}
private List<Pair<Manager, Manager.ReceiveMessageHandler>> subscribeReceiveHandlers(
- final List<Manager> managers, final ServerSentEventSender sender, Callable unsubscribe
+ final List<Manager> managers,
+ final ServerSentEventSender sender,
+ Callable unsubscribe
) {
return managers.stream().map(m1 -> {
final var receiveMessageHandler = new JsonReceiveMessageHandler(m1, s -> {