org.springframework.http.codec.multipart

Class SynchronossPartHttpMessageReader.SynchronossPartGenerator

java.lang.Object

org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader.SynchronossPartGenerator

All Implemented Interfaces:

java.util.function.Consumer<<any>>

Enclosing class:

SynchronossPartHttpMessageReader

private static class SynchronossPartHttpMessageReader.SynchronossPartGenerator
extends java.lang.Object
implements java.util.function.Consumer<<any>>

Consume and feed input to the Synchronoss parser, then listen for parser output events and adapt to Flux<Sink<Part>>.

Field Summary

Fields

Modifier and Type	Field and Description
private DataBufferFactory	bufferFactory
private ReactiveHttpInputMessage	inputMessage
private PartBodyStreamStorageFactory	streamStorageFactory

Constructor Summary

Constructors

Constructor and Description
SynchronossPartGenerator(ReactiveHttpInputMessage inputMessage, DataBufferFactory bufferFactory, PartBodyStreamStorageFactory streamStorageFactory)

Method Summary

Modifier and Type	Method and Description
void	accept(<any> emitter)
private int	getContentLength(HttpHeaders headers)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Field Detail

inputMessage

private final ReactiveHttpInputMessage inputMessage

bufferFactory

private final DataBufferFactory bufferFactory

streamStorageFactory

private final PartBodyStreamStorageFactory streamStorageFactory

Constructor Detail

SynchronossPartGenerator

SynchronossPartGenerator(ReactiveHttpInputMessage inputMessage,
                         DataBufferFactory bufferFactory,
                         PartBodyStreamStorageFactory streamStorageFactory)

Method Detail

accept

public void accept(<any> emitter)

Specified by:

accept in interface java.util.function.Consumer<<any>>

getContentLength

private int getContentLength(HttpHeaders headers)