Index

A B C D E F G H I M N O P R S T U V W 
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 TransportFactory and 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_type set 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 cause record 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 Channel that sends requests and receives correlated responses.
ClientSocketTransportFactory - Class in io.bytestreams.exchange.core
A TransportFactory that 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 ErrorContext record 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 from GlobalOpenTelemetry.
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 ClientChannel backed by a Transport using 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 ClientChannel backed by a Transport using 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 request record 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 Transport decorator that automatically reconnects using a TransportFactory when 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 response record 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
A Channel backed by a Transport that receives requests and dispatches them to a registered handler.
ServerChannel.Builder<REQ,RESP> - Class in io.bytestreams.exchange.core
Builder for ServerChannel.
ServerSocketTransportFactory - Class in io.bytestreams.exchange.core
A TransportFactory that accepts incoming TCP connections on a ServerSocket.
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 MultiplexedChannel where 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 from GlobalOpenTelemetry.
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 Transport instances.
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
 
A B C D E F G H I M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form