private static class SynchronossPartHttpMessageReader.FluxSinkAdapterListener
extends java.lang.Object
Flux<Sink<Part>>
.Modifier and Type | Field and Description |
---|---|
private DataBufferFactory |
bufferFactory |
private MultipartContext |
context |
private <any> |
sink |
private java.util.concurrent.atomic.AtomicInteger |
terminated |
Constructor and Description |
---|
FluxSinkAdapterListener(<any> sink,
DataBufferFactory bufferFactory,
MultipartContext context) |
Modifier and Type | Method and Description |
---|---|
private Part |
createPart(StreamStorage storage,
HttpHeaders httpHeaders) |
void |
onAllPartsFinished() |
void |
onError(java.lang.String message,
java.lang.Throwable cause) |
void |
onNestedPartFinished() |
void |
onNestedPartStarted(java.util.Map<java.lang.String,java.util.List<java.lang.String>> headersFromParentPart) |
void |
onPartFinished(StreamStorage storage,
java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers) |
private final <any> sink
private final DataBufferFactory bufferFactory
private final MultipartContext context
private final java.util.concurrent.atomic.AtomicInteger terminated
FluxSinkAdapterListener(<any> sink, DataBufferFactory bufferFactory, MultipartContext context)
public void onPartFinished(StreamStorage storage, java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers)
private Part createPart(StreamStorage storage, HttpHeaders httpHeaders)
public void onError(java.lang.String message, java.lang.Throwable cause)
public void onAllPartsFinished()
public void onNestedPartStarted(java.util.Map<java.lang.String,java.util.List<java.lang.String>> headersFromParentPart)
public void onNestedPartFinished()