Programmiererforum

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

}

Ich habe eine Schnittstelle mit Standardmethoden zum Senden eines Werts:
[code]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);
}

}

[/code]
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?