Project Reactor, использующий приемник Flux для отправки данных с задержкой. ⇐ JAVA

[Anonymous]

У меня есть интерфейс с методами по умолчанию для отправки значения:

Код: Выделить всё

import org.springframework.web.reactive.socket.WebSocketMessage;
import reactor.core.publisher.FluxSink;

public interface ISocketClient {

default FluxSink sendMessage(MessageObject outbound) {
WebSocketMessage message = getSerializer().serialize(outbound);
FluxSink connection = getConnection();
return connection.next(message);
}

}

Сервер быстро отвечает клиенту, и я хочу это контролировать. Можно ли добавить некоторую задержку к каждой отправке?

Подробнее здесь: https://stackoverflow.com/questions/793 ... with-delay