Uses of Class
io.bytestreams.exchange.core.PipelinedChannel.Builder
-
Uses of PipelinedChannel.Builder in io.bytestreams.exchange.core
Methods in io.bytestreams.exchange.core that return PipelinedChannel.BuilderModifier and TypeMethodDescriptionstatic <REQ,RESP>
PipelinedChannel.Builder<REQ, RESP> PipelinedChannel.builder()PipelinedChannel.Builder.defaultTimeout(Duration defaultTimeout) PipelinedChannel.Builder.errorBackoff(Duration errorBackoff) PipelinedChannel.Builder.errorHandler(ErrorHandler<REQ, RESP> errorHandler) PipelinedChannel.Builder.maxConcurrency(int maxConcurrency) PipelinedChannel.Builder.meter(io.opentelemetry.api.metrics.Meter meter) PipelinedChannel.Builder.requestWriter(MessageWriter<REQ> requestWriter) PipelinedChannel.Builder.responseReader(MessageReader<RESP> responseReader) PipelinedChannel.Builder.tracer(io.opentelemetry.api.trace.Tracer tracer) PipelinedChannel.Builder.writeBufferSize(int writeBufferSize)