public class LocalConnector.LocalEndPoint extends ByteArrayEndPoint
Constructor and Description |
---|
LocalEndPoint() |
Modifier and Type | Method and Description |
---|---|
void |
doShutdownOutput() |
protected void |
execute(java.lang.Runnable task) |
java.lang.String |
getResponse()
Wait for a response using a parser to detect the end of message
|
java.lang.String |
getResponse(boolean head,
long time,
java.util.concurrent.TimeUnit unit)
Wait for a response using a parser to detect the end of message
|
java.nio.ByteBuffer |
getResponseData()
Remaining output ByteBuffer after calls to
getResponse() or waitForResponse(boolean, long, TimeUnit) |
void |
onClose()
Callback method invoked when this
EndPoint is close. |
java.nio.ByteBuffer |
waitForResponse(boolean head,
long time,
java.util.concurrent.TimeUnit unit)
Wait for a response using a parser to detect the end of message
|
void |
waitUntilClosed() |
void |
waitUntilClosedOrIdleFor(long idleFor,
java.util.concurrent.TimeUnit units) |
addInput, addInput, addInput, addInputAndExecute, addInputEOF, doClose, fill, flush, getLocalAddress, getOutput, getOutputString, getOutputString, getRemoteAddress, getTransport, hasMore, isGrowOutput, needsFillInterest, onIncompleteFlush, reset, setGrowOutput, setOutput, takeOutput, takeOutputString, takeOutputString, toString, waitForOutput
checkFill, checkFlush, close, close, doShutdownInput, fillInterested, getConnection, getCreatedTimeStamp, getFillInterest, getWriteFlusher, isFillInterested, isInputShutdown, isOpen, isOptimizedForDirectBuffers, isOutputShutdown, onClose, onIdleExpired, onOpen, setConnection, shutdownInput, shutdownOutput, toConnectionString, toEndPointString, tryFillInterested, upgrade, write
checkIdleTimeout, getIdleFor, getIdleTimeout, getIdleTimestamp, getScheduler, notIdle, setIdleTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getIdleTimeout, setIdleTimeout
protected void execute(java.lang.Runnable task)
execute
in class ByteArrayEndPoint
public void onClose()
EndPoint
Callback method invoked when this EndPoint
is close.
onClose
in interface EndPoint
onClose
in class AbstractEndPoint
EndPoint.onOpen()
public void doShutdownOutput()
doShutdownOutput
in class ByteArrayEndPoint
public void waitUntilClosed()
public void waitUntilClosedOrIdleFor(long idleFor, java.util.concurrent.TimeUnit units)
public java.nio.ByteBuffer getResponseData()
getResponse()
or waitForResponse(boolean, long, TimeUnit)
public java.lang.String getResponse() throws java.lang.Exception
java.lang.Exception
- if the response cannot be parsedpublic java.lang.String getResponse(boolean head, long time, java.util.concurrent.TimeUnit unit) throws java.lang.Exception
head
- whether the request is a HEAD requesttime
- the maximum time to waitunit
- the time unit of the timeout
argumentjava.lang.Exception
- if the response cannot be parsedpublic java.nio.ByteBuffer waitForResponse(boolean head, long time, java.util.concurrent.TimeUnit unit) throws java.lang.Exception
head
- whether the request is a HEAD requesttime
- the maximum time to waitunit
- the time unit of the timeout
argumentjava.lang.Exception
- if the response cannot be parsedCopyright © 1995–2023 Webtide. All rights reserved.