Package dev.shamoo.runtime.core

Class OptionalProxyTransport

java.lang.Object

dev.shamoo.runtime.core.OptionalProxyTransport

All Implemented Interfaces:

AutoCloseable

public final class OptionalProxyTransport
extends Object
implements AutoCloseable

Optional correlated request transport over an allowlisted raw plugin-message sender.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	OptionalProxyTransport.Response	Explicit distinction between an absent carrier/proxy, a canonical response frame, and a local transport error.
static interface	OptionalProxyTransport.Sender

Constructor Summary

Constructors

Constructor	Description
OptionalProxyTransport(Duration timeout)

Method Summary

Modifier and Type	Method	Description
void	carrier(OptionalProxyTransport.Sender availableSender)
void	clearCarrier()
void	close()
boolean	receive(byte[] encoded, boolean validSource)	Accepts only validated responses from the expected platform source.
CompletionStage<OptionalProxyTransport.Response>	request(byte[] requestFrame)	Sends one already encoded canonical request frame and returns the complete correlated response frame.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OptionalProxyTransport

public OptionalProxyTransport(Duration timeout)

Method Details

carrier

public void carrier(OptionalProxyTransport.Sender availableSender)

clearCarrier

public void clearCarrier()

request

public CompletionStage<OptionalProxyTransport.Response> request(byte[] requestFrame)

Sends one already encoded canonical request frame and returns the complete correlated response frame.

receive

public boolean receive(byte[] encoded,
 boolean validSource)

Accepts only validated responses from the expected platform source.

close

public void close()

Specified by:

close in interface AutoCloseable