io.micronaut.http.server.netty.multipart

Class NettyStreamingFileUpload

java.lang.Object

io.micronaut.http.server.netty.multipart.NettyStreamingFileUpload

All Implemented Interfaces:

FileUpload, StreamingFileUpload, org.reactivestreams.Publisher<PartData>

@Internal
public class NettyStreamingFileUpload
extends java.lang.Object
implements StreamingFileUpload

An implementation of the StreamingFileUpload interface for Netty.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
NettyStreamingFileUpload(io.netty.handler.codec.http.multipart.FileUpload httpData, HttpServerConfiguration.MultipartConfiguration multipartConfiguration, java.util.concurrent.ExecutorService ioExecutor, io.reactivex.Flowable subject)

Method Summary

Modifier and Type	Method and Description
protected java.io.File	createTemp(java.lang.String location)
org.reactivestreams.Publisher<java.lang.Boolean>	delete() Deletes the underlying storage for a file item, including deleting any associated temporary disk file.
java.util.Optional<MediaType>	getContentType() Gets the content type of this part.
long	getDefinedSize() Returns the defined content length of the part.
java.lang.String	getFilename() Gets the name of this part.
java.lang.String	getName() Gets the name of this part.
long	getSize() Returns the size of the part.
boolean	isComplete() Returns whether the FileUpload has been fully uploaded or is in a partial state.
void	subscribe(org.reactivestreams.Subscriber<? super PartData> s)
org.reactivestreams.Publisher<java.lang.Boolean>	transferTo(java.io.File destination) A convenience method to write this uploaded item to disk.
org.reactivestreams.Publisher<java.lang.Boolean>	transferTo(java.lang.String location) A convenience method to write this uploaded item to disk.

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyStreamingFileUpload

public NettyStreamingFileUpload(io.netty.handler.codec.http.multipart.FileUpload httpData,
                                HttpServerConfiguration.MultipartConfiguration multipartConfiguration,
                                java.util.concurrent.ExecutorService ioExecutor,
                                io.reactivex.Flowable subject)

Parameters:

httpData - The file upload (the data)

multipartConfiguration - The multipart configuration

ioExecutor - The IO executor

subject - The subject

Method Detail

getContentType

public java.util.Optional<MediaType> getContentType()

Description copied from interface: FileUpload

Gets the content type of this part.

Specified by:

getContentType in interface FileUpload

Returns:

The content type of this part.

getName

public java.lang.String getName()

Description copied from interface: FileUpload

Gets the name of this part.

Specified by:

getName in interface FileUpload

Returns:

The name of this part

getFilename

public java.lang.String getFilename()

Description copied from interface: FileUpload

Gets the name of this part.

Specified by:

getFilename in interface FileUpload

Returns:

The name of this part

getSize

public long getSize()

Description copied from interface: FileUpload

Returns the size of the part.

Specified by:

getSize in interface FileUpload

Returns:

The size of this part, in bytes.

getDefinedSize

public long getDefinedSize()

Description copied from interface: FileUpload

Returns the defined content length of the part.

Specified by:

getDefinedSize in interface FileUpload

Returns:

The content length of this part, in bytes.

isComplete

public boolean isComplete()

Description copied from interface: FileUpload

Returns whether the FileUpload has been fully uploaded or is in a partial state.

Specified by:

isComplete in interface FileUpload

Returns:

True if the part is fully uploaded

transferTo

public org.reactivestreams.Publisher<java.lang.Boolean> transferTo(java.lang.String location)

Description copied from interface: StreamingFileUpload

A convenience method to write this uploaded item to disk.

This method will return a no-op Publisher if called multiple times for the same location

Specified by:

transferTo in interface StreamingFileUpload

Parameters:

location - the name of the file to which the stream will be written. The file is created relative to the location as specified in the MultipartConfiguration

Returns:

A Publisher that outputs whether the transfer was successful

transferTo

public org.reactivestreams.Publisher<java.lang.Boolean> transferTo(java.io.File destination)

Description copied from interface: StreamingFileUpload

A convenience method to write this uploaded item to disk.

This method will return a no-op Publisher if called multiple times for the same location

Specified by:

transferTo in interface StreamingFileUpload

Parameters:

destination - the destination of the file to which the stream will be written.

Returns:

A Publisher that outputs whether the transfer was successful

delete

public org.reactivestreams.Publisher<java.lang.Boolean> delete()

Description copied from interface: StreamingFileUpload

Deletes the underlying storage for a file item, including deleting any associated temporary disk file.

Specified by:

delete in interface StreamingFileUpload

Returns:

A Publisher that outputs whether the delete was successful

createTemp

protected java.io.File createTemp(java.lang.String location)

Parameters:

location - The location for the temp file

Returns:

The temporal file

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super PartData> s)

Specified by:

subscribe in interface org.reactivestreams.Publisher<PartData>