public class SignalJsonRpcDispatcherHandler {
- private final static Logger logger = LoggerFactory.getLogger(SignalJsonRpcDispatcherHandler.class);
+ private static final Logger logger = LoggerFactory.getLogger(SignalJsonRpcDispatcherHandler.class);
private final ObjectMapper objectMapper;
private final JsonRpcSender jsonRpcSender;
private void unsubscribeReceive(final Manager m) {
final var subscriptionId = receiveHandlers.entrySet()
.stream()
- .filter(e -> e.getValue().size() == 1 && e.getValue().get(0).first().equals(m))
+ .filter(e -> e.getValue().size() == 1 && e.getValue().getFirst().first().equals(m))
.map(Map.Entry::getKey)
.findFirst();
subscriptionId.ifPresent(this::unsubscribeReceive);
}
private Integer getSubscriptionId(final JsonNode request) {
- if (request instanceof ArrayNode req) {
- return req.get(0).asInt();
- } else if (request instanceof ObjectNode req) {
- return req.get("subscription").asInt();
- } else {
- return null;
- }
+ return switch (request) {
+ case ArrayNode req -> req.get(0).asInt();
+ case ObjectNode req -> req.get("subscription").asInt();
+ case null, default -> null;
+ };
}
}
}