private static final class ConnectionManager.ReqIterator extends Object implements OutboundRequestIterator
Modifier and Type | Field and Description |
---|---|
private boolean |
first
True if next has not yet been called.
|
private OutboundRequestHandle |
handle
The request handle.
|
private ConnectionManager |
manager
ConnectionManager
|
private ConnectionManager.OutboundMux |
mux
The outbound mux from the last call to next, if any.
|
Constructor and Description |
---|
ReqIterator(OutboundRequestHandle handle,
ConnectionManager cm) |
Modifier and Type | Method and Description |
---|---|
boolean |
hasNext()
Returns true if next has not yet been called or if the last mux
returned had an asynchronous close.
|
OutboundRequest |
next()
If hasNext returns true, finds the entry (if any) for the connection
endpoint.
|
private final ConnectionManager manager
private final OutboundRequestHandle handle
private boolean first
private ConnectionManager.OutboundMux mux
ReqIterator(OutboundRequestHandle handle, ConnectionManager cm)
public boolean hasNext()
hasNext
in interface OutboundRequestIterator
true
if this iterator supports making
another attempt to communicate the request, and
false
otherwisepublic OutboundRequest next() throws IOException
next
in interface OutboundRequestIterator
OutboundRequest
to use to write the
request data and read the responseIOException
- if an I/O exception occurs while performing
this operation; in this event, the recipient may have received
an indication of the request initiation attemptCopyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.