Class NonBlockingWebResponse

java.lang.Object

services.moleculer.web.servlet.response.AbstractWebResponse

services.moleculer.web.servlet.response.NonBlockingWebResponse

All Implemented Interfaces:

WebResponse

public class NonBlockingWebResponse
extends AbstractWebResponse

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicReference<Throwable>	error
protected final jakarta.servlet.WriteListener	listener
protected final AtomicBoolean	listenerSet
protected final ConcurrentLinkedQueue<byte[]>	queue
protected final AtomicBoolean	writting

Fields inherited from class AbstractWebResponse

closed, out, properties, rsp

Constructor Summary

Constructors

Constructor	Description
NonBlockingWebResponse(jakarta.servlet.AsyncContext async)

Method Summary

Modifier and Type	Method	Description
protected void	addToQueueAndSend(byte[] bytes)
boolean	end()	Completes the synchronous operation that was started on the request.
void	send(byte[] bytes)	Writes b.length bytes of body from the specified byte array to the output stream.

Methods inherited from class AbstractWebResponse

getHeader, getInternalObject, getProperty, getStatus, setHeader, setProperty, setStatus

Methods inherited from class Object

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

Field Details

error

protected final AtomicReference<Throwable> error

listenerSet

protected final AtomicBoolean listenerSet

queue

protected final ConcurrentLinkedQueue<byte[]> queue

listener

protected final jakarta.servlet.WriteListener listener

writting

protected final AtomicBoolean writting

Constructor Details

NonBlockingWebResponse

public NonBlockingWebResponse(jakarta.servlet.AsyncContext async)
                       throws IOException

Throws:

IOException

Method Details

send

public void send(byte[] bytes)
          throws IOException

Writes b.length bytes of body from the specified byte array to the output stream.

Specified by:

send in interface WebResponse

Overrides:

send in class AbstractWebResponse

Parameters:

bytes - the data

Throws:

IOException - if an I/O error occurs

end

public boolean end()

Completes the synchronous operation that was started on the request.

Specified by:

end in interface WebResponse

Overrides:

end in class AbstractWebResponse

Returns:

return true, if any resources are released

addToQueueAndSend

protected void addToQueueAndSend(byte[] bytes)