()
| 205 | } |
| 206 | |
| 207 | @GuardedBy("this") |
| 208 | final void send() throws StatusException { |
| 209 | while (canSend()) { |
| 210 | try { |
| 211 | sendInternal(); |
| 212 | } catch (StatusException se) { |
| 213 | // Ensure we don't send anything else and rethrow. |
| 214 | onOutboundState(State.CLOSED); |
| 215 | throw se; |
| 216 | } |
| 217 | } |
| 218 | } |
| 219 | |
| 220 | @GuardedBy("this") |
| 221 | @SuppressWarnings("fallthrough") |
no test coverage detected