X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/81a11dc9776672e3468ee9a8eed556889fb2e070..d248f249e37f7b35a3b7dd69f2a06af8eddd3996:/src/main/java/org/asamk/signal/jsonrpc/JsonRpcReader.java diff --git a/src/main/java/org/asamk/signal/jsonrpc/JsonRpcReader.java b/src/main/java/org/asamk/signal/jsonrpc/JsonRpcReader.java index 3bc7e701..6e58b23c 100644 --- a/src/main/java/org/asamk/signal/jsonrpc/JsonRpcReader.java +++ b/src/main/java/org/asamk/signal/jsonrpc/JsonRpcReader.java @@ -15,7 +15,6 @@ import java.io.IOException; import java.util.Objects; import java.util.function.Consumer; import java.util.function.Supplier; -import java.util.stream.Collectors; import java.util.stream.StreamSupport; public class JsonRpcReader { @@ -57,7 +56,7 @@ public class JsonRpcReader { } return handleRequest(requestHandler, request); - }).filter(Objects::nonNull).collect(Collectors.toList()); + }).filter(Objects::nonNull).toList(); jsonRpcSender.sendBatchResponses(responseList); } @@ -128,8 +127,7 @@ public class JsonRpcReader { null), null)); return null; } - return new JsonRpcBatchMessage(StreamSupport.stream(jsonNode.spliterator(), false) - .collect(Collectors.toList())); + return new JsonRpcBatchMessage(StreamSupport.stream(jsonNode.spliterator(), false).toList()); } else if (jsonNode.isObject()) { if (jsonNode.has("result") || jsonNode.has("error")) { return parseJsonRpcResponse(jsonNode);