net.bluemind.sds.store.s3.zstd

Class ZstdRequestBody

java.lang.Object

net.bluemind.sds.store.s3.zstd.ZstdRequestBody

All Implemented Interfaces:

org.reactivestreams.Publisher<java.nio.ByteBuffer>, software.amazon.awssdk.core.async.AsyncRequestBody, software.amazon.awssdk.core.async.SdkPublisher<java.nio.ByteBuffer>

public class ZstdRequestBody
extends java.lang.Object
implements software.amazon.awssdk.core.async.AsyncRequestBody

Constructor Summary

Constructors

Constructor and Description
ZstdRequestBody(java.nio.file.Path sourceFile, com.netflix.spectator.api.DistributionSummary compressionRatio)

Method Summary

Modifier and Type	Method and Description
java.util.Optional<java.lang.Long>	contentLength()
void	subscribe(org.reactivestreams.Subscriber<? super java.nio.ByteBuffer> s)

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.amazon.awssdk.core.async.AsyncRequestBody

contentType, empty, fromByteBuffer, fromBytes, fromFile, fromFile, fromPublisher, fromString, fromString

Methods inherited from interface software.amazon.awssdk.core.async.SdkPublisher

adapt, buffer, doAfterOnCancel, doAfterOnComplete, doAfterOnError, filter, filter, flatMapIterable, limit, map, subscribe

Constructor Detail

ZstdRequestBody

public ZstdRequestBody(java.nio.file.Path sourceFile,
                       com.netflix.spectator.api.DistributionSummary compressionRatio)

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super java.nio.ByteBuffer> s)

Specified by:

subscribe in interface org.reactivestreams.Publisher<java.nio.ByteBuffer>

contentLength

public java.util.Optional<java.lang.Long> contentLength()

Specified by:

contentLength in interface software.amazon.awssdk.core.async.AsyncRequestBody