Интерфейс WebSocket.Listener

Включающий интерфейс:

WebSocket

public static interface WebSocket.Listener

Примечание API:

Строгий последовательный порядок вызовов от WebSocket к Listener означает, в частности, что методы Listener обрабатываются как нерекурсивные. Это означает, что реализациям Listener не нужно беспокоиться о возможной рекурсии или порядке вызова WebSocket.request по отношению к их логике обработки.

Внимание может потребоваться, если слушатель связан с более чем одним WebSocket. В этом случае вызовы, связанные с разными экземплярами WebSocket , могут не быть упорядочены и даже происходить одновременно.

CompletionStage , возвращаемые методами приема, не имеют отношения к счетчику вызовов. Иными словами, CompletionStage не обязательно должен быть завершён, чтобы получить новые вызовы методов слушателя. Вот пример слушателя, который запрашивает вызовы по одному, пока не будет накоплено полное сообщение, затем обрабатывает результат и завершает CompletionStage:

WebSocket.Listener listener = new WebSocket.Listener() {

        List<CharSequence> parts = new ArrayList<>();
        CompletableFuture<?> accumulatedMessage = new CompletableFuture<>();

        public CompletionStage<?> onText(WebSocket webSocket,
                                         CharSequence message,
                                         boolean last) {
            parts.add(message);
            webSocket.request(1);
            if (last) {
                processWholeText(parts);
                parts = new ArrayList<>();
                accumulatedMessage.complete(null);
                CompletionStage<?> cf = accumulatedMessage;
                accumulatedMessage = new CompletableFuture<>();
                return cf;
            }
            return accumulatedMessage;
        }
    ...
    }

С:

11