net.bluemind.sds.store.s3.zstd

Class ZstdResponseTransformer<T>

java.lang.Object

net.bluemind.sds.store.s3.zstd.ZstdResponseTransformer<T>

All Implemented Interfaces:

software.amazon.awssdk.core.async.AsyncResponseTransformer<T,T>

public class ZstdResponseTransformer<T>
extends java.lang.Object
implements software.amazon.awssdk.core.async.AsyncResponseTransformer<T,T>

Constructor Summary

Constructors

Constructor and Description
ZstdResponseTransformer(java.lang.String path)

Method Summary

Modifier and Type	Method and Description
void	exceptionOccurred(java.lang.Throwable error)
void	onResponse(T response)
void	onStream(software.amazon.awssdk.core.async.SdkPublisher<java.nio.ByteBuffer> publisher)
java.util.concurrent.CompletableFuture<T>	prepare()
long	transferred()

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.AsyncResponseTransformer

toBytes, toFile, toFile

Constructor Detail

ZstdResponseTransformer

public ZstdResponseTransformer(java.lang.String path)

Method Detail

prepare

public java.util.concurrent.CompletableFuture<T> prepare()

Specified by:

prepare in interface software.amazon.awssdk.core.async.AsyncResponseTransformer<T,T>

onResponse

public void onResponse(T response)

Specified by:

onResponse in interface software.amazon.awssdk.core.async.AsyncResponseTransformer<T,T>

onStream

public void onStream(software.amazon.awssdk.core.async.SdkPublisher<java.nio.ByteBuffer> publisher)

Specified by:

onStream in interface software.amazon.awssdk.core.async.AsyncResponseTransformer<T,T>

transferred

public long transferred()

exceptionOccurred

public void exceptionOccurred(java.lang.Throwable error)

Specified by:

exceptionOccurred in interface software.amazon.awssdk.core.async.AsyncResponseTransformer<T,T>