Package io.bytestreams.exchange.core
Class PipelinedChannel.Builder<REQ,RESP>
java.lang.Object
io.bytestreams.exchange.core.PipelinedChannel.Builder<REQ,RESP>
- Enclosing class:
PipelinedChannel<REQ,RESP>
-
Method Summary
Modifier and TypeMethodDescriptionbuild()defaultTimeout(Duration defaultTimeout) errorBackoff(Duration errorBackoff) errorHandler(ErrorHandler<REQ, RESP> errorHandler) maxConcurrency(int maxConcurrency) meter(io.opentelemetry.api.metrics.Meter meter) requestWriter(MessageWriter<REQ> requestWriter) responseReader(MessageReader<RESP> responseReader) tracer(io.opentelemetry.api.trace.Tracer tracer) writeBufferSize(int writeBufferSize)
-
Method Details
-
transport
-
writeBufferSize
-
requestWriter
-
responseReader
-
maxConcurrency
-
errorHandler
-
defaultTimeout
-
errorBackoff
-
meter
-
tracer
-
build
-