org.springframework.http.codec.multipart

Class SynchronossPartHttpMessageReader.FluxSinkAdapterListener

java.lang.Object

org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader.FluxSinkAdapterListener

Enclosing class:

SynchronossPartHttpMessageReader

private static class SynchronossPartHttpMessageReader.FluxSinkAdapterListener
extends java.lang.Object

Listen for parser output and adapt to Flux<Sink<Part>>.

Field Summary

Fields

Modifier and Type	Field and Description
private DataBufferFactory	bufferFactory
private MultipartContext	context
private <any>	sink
private java.util.concurrent.atomic.AtomicInteger	terminated

Constructor Summary

Constructors

Constructor and Description
FluxSinkAdapterListener(<any> sink, DataBufferFactory factory, MultipartContext context)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Field Detail

sink

private final <any> sink

bufferFactory

private final DataBufferFactory bufferFactory

context

private final MultipartContext context

terminated

private final java.util.concurrent.atomic.AtomicInteger terminated

Constructor Detail

FluxSinkAdapterListener

FluxSinkAdapterListener(<any> sink,
                        DataBufferFactory factory,
                        MultipartContext context)

Method Detail

onPartFinished

public void onPartFinished(StreamStorage storage,
                           java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers)

createPart

private Part createPart(StreamStorage storage,
                        HttpHeaders httpHeaders)

onError

public void onError(java.lang.String message,
                    java.lang.Throwable cause)

onAllPartsFinished

public void onAllPartsFinished()

onNestedPartStarted

public void onNestedPartStarted(java.util.Map<java.lang.String,java.util.List<java.lang.String>> headersFromParentPart)

onNestedPartFinished

public void onNestedPartFinished()