Package io.bytestreams.exchange.core

Class SocketTransport

java.lang.Object

io.bytestreams.exchange.core.SocketTransport

All Implemented Interfaces:

Transport, Closeable, AutoCloseable

public final class SocketTransport
extends Object
implements Transport

Constructor Summary

Constructors

Constructor	Description
SocketTransport(Socket socket)

Method Summary

Modifier and Type	Method	Description
io.opentelemetry.api.common.Attributes	attributes()	Returns transport-level OTel attributes (e.g. network type, peer address, peer port).
void	close()
InputStream	inputStream()	Returns the input stream for reading inbound messages.
OutputStream	outputStream()	Returns the output stream for writing outbound messages.

Methods inherited from class java.lang.Object

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

Constructor Details

SocketTransport

public SocketTransport(Socket socket)

Method Details

inputStream

public InputStream inputStream()
                        throws IOException

Description copied from interface: Transport

Returns the input stream for reading inbound messages.

Specified by:

inputStream in interface Transport

Throws:

IOException

outputStream

public OutputStream outputStream()
                          throws IOException

Description copied from interface: Transport

Returns the output stream for writing outbound messages.

Specified by:

outputStream in interface Transport

Throws:

IOException

attributes

public io.opentelemetry.api.common.Attributes attributes()

Description copied from interface: Transport

Returns transport-level OTel attributes (e.g. network type, peer address, peer port).

Specified by:

attributes in interface Transport

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Transport

Throws:

IOException