NonBlockingWebResponse (moleculer-java-web 1.2.2 API)

java.lang.Object
- services.moleculer.web.servlet.response.AbstractWebResponse
- - services.moleculer.web.servlet.response.NonBlockingWebResponse

public class NonBlockingWebResponse
extends AbstractWebResponse

Fields
Modifier and Type	Field and Description
`protected static byte[]`	`END_MARKER`
`protected java.util.concurrent.atomic.AtomicReference<java.lang.Throwable>`	`error`
`protected javax.servlet.WriteListener`	`listener`
`protected java.util.concurrent.atomic.AtomicBoolean`	`listenerSet`
`protected java.util.concurrent.atomic.AtomicBoolean`	`lock`
`protected java.util.LinkedList<byte[]>`	`queue`

Fields inherited from class services.moleculer.web.servlet.response.AbstractWebResponse
closed, out, properties, rsp

Constructors
Constructor and Description
`NonBlockingWebResponse(javax.servlet.AsyncContext async)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and 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 services.moleculer.web.servlet.response.AbstractWebResponse
getHeader, getProperty, getStatus, setHeader, setProperty, setStatus

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

protected static final byte[] END_MARKER

protected final java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> error

protected final java.util.concurrent.atomic.AtomicBoolean listenerSet

protected final java.util.concurrent.atomic.AtomicBoolean lock

protected final java.util.LinkedList<byte[]> queue

protected final javax.servlet.WriteListener listener

public NonBlockingWebResponse(javax.servlet.AsyncContext async)
                       throws java.io.IOException

Class NonBlockingWebResponse