Projektreaktor, der eine Flux-Senke verwendet, um Daten mit Verzögerung zu senden
Posted: 13 Jan 2025, 18:52
Ich habe eine Schnittstelle mit Standardmethoden zum Senden eines Werts:
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?
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);
}
}