Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- AbstractChannel<OUT,
IN> - Class in io.bytestreams.exchange.core -
Base class for
Transport-backed channels with managed I/O loops. - Acceptor - Class in io.bytestreams.exchange.core
-
Accepts transports from a
TransportFactoryand creates channels for each. - Acceptor.Builder - Class in io.bytestreams.exchange.core
- attributes() - Method in class io.bytestreams.exchange.core.ResilientTransport
- attributes() - Method in class io.bytestreams.exchange.core.SocketTransport
- attributes() - Method in interface io.bytestreams.exchange.core.Transport
-
Returns transport-level OTel attributes (e.g. network type, peer address, peer port).
B
- backlog(int) - Method in class io.bytestreams.exchange.core.ServerSocketTransportFactory.Builder
- backoffStrategy(BackoffStrategy) - Method in class io.bytestreams.exchange.core.ResilientTransport.Builder
- BackoffStrategy - Interface in io.bytestreams.exchange.core
-
Strategy for computing the delay between retry attempts.
- build() - Method in class io.bytestreams.exchange.core.Acceptor.Builder
- build() - Method in class io.bytestreams.exchange.core.ClientSocketTransportFactory.Builder
- build() - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- build() - Method in class io.bytestreams.exchange.core.PipelinedChannel.Builder
- build() - Method in class io.bytestreams.exchange.core.ResilientTransport.Builder
- build() - Method in class io.bytestreams.exchange.core.ServerChannel.Builder
- build() - Method in class io.bytestreams.exchange.core.ServerSocketTransportFactory.Builder
- build() - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
- builder() - Static method in class io.bytestreams.exchange.core.MultiplexedChannel
- builder() - Static method in class io.bytestreams.exchange.core.PipelinedChannel
- builder() - Static method in class io.bytestreams.exchange.core.ServerChannel
- builder(int) - Static method in class io.bytestreams.exchange.core.ServerSocketTransportFactory
- builder(TransportFactory) - Static method in class io.bytestreams.exchange.core.Acceptor
- builder(TransportFactory) - Static method in class io.bytestreams.exchange.core.ResilientTransport
- builder(String, int) - Static method in class io.bytestreams.exchange.core.ClientSocketTransportFactory
- buildMessageAttributes(Object) - Method in class io.bytestreams.exchange.core.AbstractChannel
-
Returns metric attributes for a message, including
message_typeset to the simple class name of the given message.
C
- cause() - Method in record class io.bytestreams.exchange.core.ErrorContext
-
Returns the value of the
causerecord component. - Channel - Interface in io.bytestreams.exchange.core
-
A logical messaging channel between two endpoints.
- CHANNEL_ID - Static variable in class io.bytestreams.exchange.core.OTel
- CHANNEL_TYPE - Static variable in class io.bytestreams.exchange.core.OTel
- channelFactory(Function<Transport, Channel>) - Method in class io.bytestreams.exchange.core.Acceptor.Builder
- channelSpan - Variable in class io.bytestreams.exchange.core.AbstractChannel
- ChannelStatus - Enum Class in io.bytestreams.exchange.core
-
The lifecycle status of a
Channel. - ClientChannel<REQ,
RESP> - Interface in io.bytestreams.exchange.core -
A
Channelthat sends requests and receives correlated responses. - ClientSocketTransportFactory - Class in io.bytestreams.exchange.core
-
A
TransportFactorythat creates client-side TCP connections. - ClientSocketTransportFactory.Builder - Class in io.bytestreams.exchange.core
- close() - Method in class io.bytestreams.exchange.core.AbstractChannel
- close() - Method in class io.bytestreams.exchange.core.Acceptor
-
Closes the acceptor, the transport factory (if
Closeable), and all tracked channels. - close() - Method in interface io.bytestreams.exchange.core.Channel
-
Closes this channel gracefully.
- close() - Method in class io.bytestreams.exchange.core.ResilientTransport
- close() - Method in class io.bytestreams.exchange.core.ServerSocketTransportFactory
- close() - Method in class io.bytestreams.exchange.core.SocketTransport
- close() - Method in interface io.bytestreams.exchange.core.Transport
- CLOSED - Enum constant in enum class io.bytestreams.exchange.core.ChannelStatus
-
Permanently closed.
- closeFuture - Variable in class io.bytestreams.exchange.core.AbstractChannel
- closeFuture() - Method in class io.bytestreams.exchange.core.AbstractChannel
-
Returns a defensive copy of the close future.
- closeFuture() - Method in class io.bytestreams.exchange.core.Acceptor
- closeFuture() - Method in interface io.bytestreams.exchange.core.Channel
-
Returns a future that completes when this channel is fully closed, without triggering close.
- CLOSING - Enum constant in enum class io.bytestreams.exchange.core.ChannelStatus
-
Shutting down gracefully; no new requests accepted.
- configure(Socket) - Method in interface io.bytestreams.exchange.core.SocketConfigurator
-
Configures the given socket.
- connectTimeoutMillis(int) - Method in class io.bytestreams.exchange.core.ClientSocketTransportFactory.Builder
- create() - Method in class io.bytestreams.exchange.core.ClientSocketTransportFactory
- create() - Method in class io.bytestreams.exchange.core.ServerSocketTransportFactory
- create() - Method in interface io.bytestreams.exchange.core.TransportFactory
-
Creates a new transport.
D
- DEFAULT - Static variable in interface io.bytestreams.exchange.core.SocketConfigurator
-
A no-op configurator that leaves the socket with default settings.
- DEFAULT_ERROR_BACKOFF_NANOS - Static variable in class io.bytestreams.exchange.core.AbstractChannel
- defaultTimeout - Variable in class io.bytestreams.exchange.core.AbstractChannel
- defaultTimeout(Duration) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- defaultTimeout(Duration) - Method in class io.bytestreams.exchange.core.PipelinedChannel.Builder
- defaultTimeout(Duration) - Method in class io.bytestreams.exchange.core.ServerChannel.Builder
- defaultTimeout(Duration) - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
- delay(int) - Method in interface io.bytestreams.exchange.core.BackoffStrategy
-
Computes the delay before the given attempt.
- DIRECTION - Static variable in class io.bytestreams.exchange.core.OTel
- DuplicateCorrelationIdException - Exception Class in io.bytestreams.exchange.core
-
Thrown when a message's correlation id is already pending.
E
- endSpan(Span, Throwable) - Static method in class io.bytestreams.exchange.core.OTel
- equals(Object) - Method in record class io.bytestreams.exchange.core.ErrorContext
-
Indicates whether some other object is "equal to" this one.
- ERROR_TYPE - Static variable in class io.bytestreams.exchange.core.OTel
- errorBackoff(Duration) - Method in class io.bytestreams.exchange.core.Acceptor.Builder
- errorBackoff(Duration) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- errorBackoff(Duration) - Method in class io.bytestreams.exchange.core.PipelinedChannel.Builder
- errorBackoff(Duration) - Method in class io.bytestreams.exchange.core.ServerChannel.Builder
- errorBackoff(Duration) - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
- ErrorContext<REQ,
RESP> - Record Class in io.bytestreams.exchange.core -
Structured context for a channel error, carrying the cause and any associated request/response.
- ErrorContext(Throwable, Optional<REQ>, Optional<RESP>) - Constructor for record class io.bytestreams.exchange.core.ErrorContext
-
Creates an instance of a
ErrorContextrecord class. - errorHandler - Variable in class io.bytestreams.exchange.core.MultiplexedChannel
- errorHandler - Variable in class io.bytestreams.exchange.core.PipelinedChannel
- errorHandler - Variable in class io.bytestreams.exchange.core.SymmetricChannel
- errorHandler(ErrorHandler<REQ, RESP>) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- errorHandler(ErrorHandler<REQ, RESP>) - Method in class io.bytestreams.exchange.core.PipelinedChannel.Builder
- errorHandler(ErrorHandler<REQ, RESP>) - Method in class io.bytestreams.exchange.core.ServerChannel.Builder
- errorHandler(ErrorHandler<T, T>) - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
- ErrorHandler<REQ,
RESP> - Interface in io.bytestreams.exchange.core -
Handles channel errors.
- exponential(Duration) - Static method in interface io.bytestreams.exchange.core.BackoffStrategy
-
Returns a strategy that doubles the base delay on each attempt:
baseDelay * 2^(attempt - 1). - Extension Points - Search tag in package io.bytestreams.exchange.core
- Section
F
- fixed(Duration) - Static method in interface io.bytestreams.exchange.core.BackoffStrategy
-
Returns a strategy that always returns the same delay.
G
- getMessageId() - Method in exception class io.bytestreams.exchange.core.DuplicateCorrelationIdException
H
- handle(REQ, CompletableFuture<RESP>) - Method in interface io.bytestreams.exchange.core.RequestHandler
- hashCode() - Method in record class io.bytestreams.exchange.core.ErrorContext
-
Returns a hash code value for this object.
- hasPending() - Method in class io.bytestreams.exchange.core.AbstractChannel
- hasPending() - Method in class io.bytestreams.exchange.core.MultiplexedChannel
- hasPending() - Method in class io.bytestreams.exchange.core.PipelinedChannel
- hasPending() - Method in class io.bytestreams.exchange.core.ServerChannel
- hasPending() - Method in class io.bytestreams.exchange.core.SymmetricChannel
- host(String) - Method in class io.bytestreams.exchange.core.ServerSocketTransportFactory.Builder
I
- id() - Method in class io.bytestreams.exchange.core.AbstractChannel
- id() - Method in interface io.bytestreams.exchange.core.Channel
-
Returns a stable identifier for this channel.
- idExtractor(Function<T, String>) - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
- Implementations - Search tag in package io.bytestreams.exchange.core
- Section
- INBOUND - Enum constant in enum class io.bytestreams.exchange.core.OTel.Direction
- INIT - Enum constant in enum class io.bytestreams.exchange.core.ChannelStatus
-
Constructed but not yet started.
- inputStream() - Method in class io.bytestreams.exchange.core.ResilientTransport
- inputStream() - Method in class io.bytestreams.exchange.core.SocketTransport
- inputStream() - Method in interface io.bytestreams.exchange.core.Transport
-
Returns the input stream for reading inbound messages.
- Interfaces - Search tag in package io.bytestreams.exchange.core
- Section
- interruptIfDrained() - Method in class io.bytestreams.exchange.core.AbstractChannel
-
Interrupts the reader thread if the channel is shutting down and no work remains.
- io.bytestreams.exchange.core - package io.bytestreams.exchange.core
-
Core interfaces and channels for application protocol messaging.
M
- maxAttempts(int) - Method in class io.bytestreams.exchange.core.ResilientTransport.Builder
- maxConcurrency(int) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- maxConcurrency(int) - Method in class io.bytestreams.exchange.core.PipelinedChannel.Builder
- maxConcurrency(int) - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
- MESSAGE_ID - Static variable in class io.bytestreams.exchange.core.OTel
- MESSAGE_TYPE - Static variable in class io.bytestreams.exchange.core.OTel
- MessageReader<T> - Interface in io.bytestreams.exchange.core
-
Reads a message from an input stream.
- MessageWriter<T> - Interface in io.bytestreams.exchange.core
-
Writes a message to an output stream.
- meter() - Static method in class io.bytestreams.exchange.core.OTel
-
Returns the default
Meter, resolved lazily fromGlobalOpenTelemetry. - meter(Meter) - Method in class io.bytestreams.exchange.core.Acceptor.Builder
- meter(Meter) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- meter(Meter) - Method in class io.bytestreams.exchange.core.PipelinedChannel.Builder
- meter(Meter) - Method in class io.bytestreams.exchange.core.ResilientTransport.Builder
- meter(Meter) - Method in class io.bytestreams.exchange.core.ServerChannel.Builder
- meter(Meter) - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
- meterAttributes - Variable in class io.bytestreams.exchange.core.AbstractChannel
- MultiplexedChannel<REQ,
RESP> - Class in io.bytestreams.exchange.core -
A
ClientChannelbacked by aTransportusing ID-based (multiplexed) correlation. - MultiplexedChannel.Builder<REQ,
RESP> - Class in io.bytestreams.exchange.core
N
- NAMESPACE - Static variable in class io.bytestreams.exchange.core.OTel
- NANOS_PER_MS - Static variable in class io.bytestreams.exchange.core.OTel
- NETWORK_PEER_ADDRESS - Static variable in class io.bytestreams.exchange.core.OTel
- NETWORK_PEER_PORT - Static variable in class io.bytestreams.exchange.core.OTel
- NETWORK_TRANSPORT - Static variable in class io.bytestreams.exchange.core.OTel
- NETWORK_TYPE - Static variable in class io.bytestreams.exchange.core.OTel
- noop() - Static method in interface io.bytestreams.exchange.core.UnhandledMessageHandler
O
- onInbound(IN) - Method in class io.bytestreams.exchange.core.AbstractChannel
- onInbound(REQ) - Method in class io.bytestreams.exchange.core.ServerChannel
- onInbound(RESP) - Method in class io.bytestreams.exchange.core.MultiplexedChannel
- onInbound(RESP) - Method in class io.bytestreams.exchange.core.PipelinedChannel
- onMessage(T) - Method in interface io.bytestreams.exchange.core.UnhandledMessageHandler
- onUncorrelatedMessage(RESP) - Method in class io.bytestreams.exchange.core.MultiplexedChannel
-
Called when the read loop receives a response that cannot be correlated to any pending request.
- onUncorrelatedMessage(T) - Method in class io.bytestreams.exchange.core.SymmetricChannel
-
Called by the read loop for inbound messages that cannot be correlated to a pending outbound request.
- OTel - Class in io.bytestreams.exchange.core
-
OpenTelemetry constants and helpers.
- OTel.Direction - Enum Class in io.bytestreams.exchange.core
-
Identifies the traffic direction for a channel, used as an OTel metric attribute.
- OUTBOUND - Enum constant in enum class io.bytestreams.exchange.core.OTel.Direction
- outputStream() - Method in class io.bytestreams.exchange.core.ResilientTransport
- outputStream() - Method in class io.bytestreams.exchange.core.SocketTransport
- outputStream() - Method in interface io.bytestreams.exchange.core.Transport
-
Returns the output stream for writing outbound messages.
P
- PipelinedChannel<REQ,
RESP> - Class in io.bytestreams.exchange.core -
A
ClientChannelbacked by aTransportusing positional (pipelined) correlation. - PipelinedChannel.Builder<REQ,
RESP> - Class in io.bytestreams.exchange.core - port() - Method in class io.bytestreams.exchange.core.ServerSocketTransportFactory
-
Returns the local port this factory is bound to.
R
- read(InputStream) - Method in interface io.bytestreams.exchange.core.MessageReader
- reader(MessageReader<T>) - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
- readFuture - Variable in class io.bytestreams.exchange.core.AbstractChannel
- READY - Enum constant in enum class io.bytestreams.exchange.core.ChannelStatus
-
Started and ready to send/receive.
- request() - Method in record class io.bytestreams.exchange.core.ErrorContext
-
Returns the value of the
requestrecord component. - request(REQ) - Method in class io.bytestreams.exchange.core.MultiplexedChannel
- request(REQ) - Method in class io.bytestreams.exchange.core.PipelinedChannel
- request(T) - Method in class io.bytestreams.exchange.core.SymmetricChannel
- request(REQ) - Method in interface io.bytestreams.exchange.core.ClientChannel
-
Sends a message using the channel's configured default timeout and returns a future that completes when a correlated response arrives.
- request(REQ, Duration) - Method in class io.bytestreams.exchange.core.MultiplexedChannel
- request(REQ, Duration) - Method in class io.bytestreams.exchange.core.PipelinedChannel
- request(T, Duration) - Method in class io.bytestreams.exchange.core.SymmetricChannel
- request(REQ, Duration) - Method in interface io.bytestreams.exchange.core.ClientChannel
-
Sends a message with a per-request timeout override.
- requestActive - Variable in class io.bytestreams.exchange.core.AbstractChannel
- requestDuration - Variable in class io.bytestreams.exchange.core.AbstractChannel
- requestErrors - Variable in class io.bytestreams.exchange.core.AbstractChannel
- requestHandler(RequestHandler<REQ, RESP>) - Method in class io.bytestreams.exchange.core.ServerChannel.Builder
- requestHandler(RequestHandler<T, T>) - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
- RequestHandler<REQ,
RESP> - Interface in io.bytestreams.exchange.core -
Handles an incoming request by completing the given future with a response.
- requestIdExtractor(Function<REQ, String>) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- requestReader(MessageReader<REQ>) - Method in class io.bytestreams.exchange.core.ServerChannel.Builder
- requestTotal - Variable in class io.bytestreams.exchange.core.AbstractChannel
- requestWriter(MessageWriter<REQ>) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- requestWriter(MessageWriter<REQ>) - Method in class io.bytestreams.exchange.core.PipelinedChannel.Builder
- ResilientTransport - Class in io.bytestreams.exchange.core
-
A
Transportdecorator that automatically reconnects using aTransportFactorywhen the underlying transport fails. - ResilientTransport.Builder - Class in io.bytestreams.exchange.core
- response() - Method in record class io.bytestreams.exchange.core.ErrorContext
-
Returns the value of the
responserecord component. - responseIdExtractor(Function<RESP, String>) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- responseReader(MessageReader<RESP>) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- responseReader(MessageReader<RESP>) - Method in class io.bytestreams.exchange.core.PipelinedChannel.Builder
- responseWriter(MessageWriter<RESP>) - Method in class io.bytestreams.exchange.core.ServerChannel.Builder
S
- SERVER_ADDRESS - Static variable in class io.bytestreams.exchange.core.OTel
- SERVER_PORT - Static variable in class io.bytestreams.exchange.core.OTel
- ServerChannel<REQ,
RESP> - Class in io.bytestreams.exchange.core - ServerChannel.Builder<REQ,
RESP> - Class in io.bytestreams.exchange.core -
Builder for
ServerChannel. - ServerSocketTransportFactory - Class in io.bytestreams.exchange.core
-
A
TransportFactorythat accepts incoming TCP connections on aServerSocket. - ServerSocketTransportFactory.Builder - Class in io.bytestreams.exchange.core
- SHUTTING_DOWN - Static variable in class io.bytestreams.exchange.core.AbstractChannel
- socketConfigurator(SocketConfigurator) - Method in class io.bytestreams.exchange.core.ClientSocketTransportFactory.Builder
- socketConfigurator(SocketConfigurator) - Method in class io.bytestreams.exchange.core.ServerSocketTransportFactory.Builder
- SocketConfigurator - Interface in io.bytestreams.exchange.core
-
Configures a
Socket. - SocketTransport - Class in io.bytestreams.exchange.core
- SocketTransport(Socket) - Constructor for class io.bytestreams.exchange.core.SocketTransport
- start() - Method in class io.bytestreams.exchange.core.AbstractChannel
- start() - Method in class io.bytestreams.exchange.core.Acceptor
-
Starts the accept loop on a virtual thread.
- start() - Method in interface io.bytestreams.exchange.core.Channel
-
Starts the channel's I/O loops.
- status - Variable in class io.bytestreams.exchange.core.AbstractChannel
- status() - Method in class io.bytestreams.exchange.core.AbstractChannel
- status() - Method in interface io.bytestreams.exchange.core.Channel
-
Returns the current lifecycle status of this channel.
- stopOnError(Channel, ErrorContext<REQ, RESP>) - Method in interface io.bytestreams.exchange.core.ErrorHandler
-
Called when an error occurs on the channel.
- symmetricBuilder() - Static method in class io.bytestreams.exchange.core.SymmetricChannel
- SymmetricChannel<T> - Class in io.bytestreams.exchange.core
-
A
MultiplexedChannelwhere request and response types are the same (T=T), enabling bidirectional symmetric messaging on a single connection. - SymmetricChannel.Builder<T> - Class in io.bytestreams.exchange.core
-
Builder for
SymmetricChannel.
T
- toString() - Method in record class io.bytestreams.exchange.core.ErrorContext
-
Returns a string representation of this record class.
- tracer - Variable in class io.bytestreams.exchange.core.MultiplexedChannel
- tracer - Variable in class io.bytestreams.exchange.core.PipelinedChannel
- tracer - Variable in class io.bytestreams.exchange.core.SymmetricChannel
- tracer() - Static method in class io.bytestreams.exchange.core.OTel
-
Returns the default
Tracer, resolved lazily fromGlobalOpenTelemetry. - tracer(Tracer) - Method in class io.bytestreams.exchange.core.Acceptor.Builder
- tracer(Tracer) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- tracer(Tracer) - Method in class io.bytestreams.exchange.core.PipelinedChannel.Builder
- tracer(Tracer) - Method in class io.bytestreams.exchange.core.ServerChannel.Builder
- tracer(Tracer) - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
- transport - Variable in class io.bytestreams.exchange.core.AbstractChannel
- transport(Transport) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- transport(Transport) - Method in class io.bytestreams.exchange.core.PipelinedChannel.Builder
- transport(Transport) - Method in class io.bytestreams.exchange.core.ServerChannel.Builder
- transport(Transport) - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
- Transport - Interface in io.bytestreams.exchange.core
-
Pluggable I/O transport that provides input/output streams and connection metadata.
- TransportFactory - Interface in io.bytestreams.exchange.core
-
Factory for creating new
Transportinstances. - Types - Search tag in package io.bytestreams.exchange.core
- Section
U
- uncorrelatedHandler(UnhandledMessageHandler<RESP>) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- UnhandledMessageHandler<T> - Interface in io.bytestreams.exchange.core
-
Callback for inbound messages that could not be correlated to a pending request in a
MultiplexedChannel. - UNIT_ATTEMPT - Static variable in class io.bytestreams.exchange.core.OTel
- UNIT_REQUEST - Static variable in class io.bytestreams.exchange.core.OTel
V
- value() - Method in enum class io.bytestreams.exchange.core.OTel.Direction
-
Returns the string value used in OTel attributes.
- valueOf(String) - Static method in enum class io.bytestreams.exchange.core.ChannelStatus
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.bytestreams.exchange.core.OTel.Direction
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class io.bytestreams.exchange.core.ChannelStatus
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.bytestreams.exchange.core.OTel.Direction
-
Returns an array containing the constants of this enum class, in the order they are declared.
W
- withError(Attributes, Throwable) - Static method in class io.bytestreams.exchange.core.OTel
-
Returns the given attributes with error_type added if the throwable is non-null.
- withJitter(double) - Method in interface io.bytestreams.exchange.core.BackoffStrategy
-
Wraps this strategy, adding random jitter up to
factor * delay. - withMax(Duration) - Method in interface io.bytestreams.exchange.core.BackoffStrategy
-
Wraps this strategy, capping the delay at the given maximum.
- write(T, OutputStream) - Method in interface io.bytestreams.exchange.core.MessageWriter
- writeBufferSize(int) - Method in class io.bytestreams.exchange.core.MultiplexedChannel.Builder
- writeBufferSize(int) - Method in class io.bytestreams.exchange.core.PipelinedChannel.Builder
- writeBufferSize(int) - Method in class io.bytestreams.exchange.core.ServerChannel.Builder
- writeBufferSize(int) - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
- writeLock - Variable in class io.bytestreams.exchange.core.MultiplexedChannel
- writeLock - Variable in class io.bytestreams.exchange.core.PipelinedChannel
- writeLock - Variable in class io.bytestreams.exchange.core.SymmetricChannel
- writeQueue - Variable in class io.bytestreams.exchange.core.AbstractChannel
- writeQueueSize - Variable in class io.bytestreams.exchange.core.AbstractChannel
- writer(MessageWriter<T>) - Method in class io.bytestreams.exchange.core.SymmetricChannel.Builder
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form