NonBlockingWebResponse (moleculer-java-web 1.3.13 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 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.ConcurrentLinkedQueue<byte[]>`	`queue`
`protected java.util.concurrent.atomic.AtomicBoolean`	`writting`

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 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

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

protected final java.util.concurrent.ConcurrentLinkedQueue<byte[]> queue

protected final javax.servlet.WriteListener listener

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

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

Class NonBlockingWebResponse