com.vaadin.flow.server.communication

Class StreamReceiverHandler

java.lang.Object

com.vaadin.flow.server.communication.StreamReceiverHandler

All Implemented Interfaces:

Serializable

public class StreamReceiverHandler
extends Object
implements Serializable

Handles StreamResource instances registered in VaadinSession.

Since:

1.0

Author:

Vaadin Ltd

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamReceiverHandler.UploadInterruptedException An UploadInterruptedException will be thrown by an ongoing upload if StreamVariable.isInterrupted() returns true.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_STREAMING_PROGRESS_EVENT_INTERVAL_MS

Constructor Summary

Constructors

Constructor and Description
StreamReceiverHandler()

Method Summary

Modifier and Type	Method and Description
protected void	doHandleMultipartFileUpload(VaadinSession session, VaadinRequest request, VaadinResponse response, StreamReceiver streamReceiver, StateNode owner) Method used to stream content from a multipart request to given StreamVariable.
protected void	doHandleXhrFilePost(VaadinSession session, VaadinRequest request, VaadinResponse response, StreamReceiver streamReceiver, StateNode owner, long contentLength) Used to stream plain file post (aka XHR2.post(File))
protected int	getProgressEventInterval() To prevent event storming, streaming progress events are sent in this interval rather than every time the buffer is filled.
void	handleRequest(VaadinSession session, VaadinRequest request, VaadinResponse response, StreamReceiver streamReceiver, String uiId, String securityKey) Handle reception of incoming stream from the client.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_STREAMING_PROGRESS_EVENT_INTERVAL_MS

public static final int DEFAULT_STREAMING_PROGRESS_EVENT_INTERVAL_MS

See Also:

Constant Field Values

Constructor Detail

StreamReceiverHandler

public StreamReceiverHandler()

Method Detail

handleRequest

public void handleRequest(VaadinSession session,
                          VaadinRequest request,
                          VaadinResponse response,
                          StreamReceiver streamReceiver,
                          String uiId,
                          String securityKey)
                   throws IOException

Handle reception of incoming stream from the client.

Parameters:

session - The session for the request

request - The request to handle

response - The response object to which a response can be written.

streamReceiver - the receiver containing the destination stream variable

uiId - id of the targeted ui

securityKey - security from the request that should match registered stream receiver id

Throws:

IOException - if an IO error occurred

doHandleMultipartFileUpload

protected void doHandleMultipartFileUpload(VaadinSession session,
                                           VaadinRequest request,
                                           VaadinResponse response,
                                           StreamReceiver streamReceiver,
                                           StateNode owner)
                                    throws IOException

Method used to stream content from a multipart request to given StreamVariable.

This method takes care of locking the session as needed and does not assume the caller has locked the session. This allows the session to be locked only when needed and not when handling the upload data.

Parameters:

session - The session containing the stream variable

request - The upload request

response - The upload response

streamReceiver - the receiver containing the destination stream variable

owner - The owner of the stream

Throws:

IOException - If there is a problem reading the request or writing the response

doHandleXhrFilePost

protected void doHandleXhrFilePost(VaadinSession session,
                                   VaadinRequest request,
                                   VaadinResponse response,
                                   StreamReceiver streamReceiver,
                                   StateNode owner,
                                   long contentLength)
                            throws IOException

Used to stream plain file post (aka XHR2.post(File))

This method takes care of locking the session as needed and does not assume the caller has locked the session. This allows the session to be locked only when needed and not when handling the upload data.

Parameters:

session - The session containing the stream variable

request - The upload request

response - The upload response

streamReceiver - the receiver containing the destination stream variable

owner - The owner of the stream

contentLength - The length of the request content

Throws:

IOException - If there is a problem reading the request or writing the response

getProgressEventInterval

protected int getProgressEventInterval()

To prevent event storming, streaming progress events are sent in this interval rather than every time the buffer is filled. This fixes #13155. To adjust this value override the method, and register your own handler in VaadinService.createRequestHandlers(). The default is 500ms, and setting it to 0 effectively restores the old behavior.

Returns:

the minimum interval to be used for streaming progress events