Projektreaktor, der eine Flux-Senke verwendet, um Daten mit Verzögerung zu senden ⇐ Java

[Guest]

Ich habe eine Schnittstelle mit Standardmethoden zum Senden eines Werts:

Code: Select all

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);
}

}

Der Server reagiert schnell auf den Client und ich möchte dies steuern. Ist es möglich, bei jedem Versand etwas Verzögerung hinzuzufügen?