(Outbound outbound, L listener)
| 153 | } |
| 154 | |
| 155 | @GuardedBy("this") |
| 156 | final void init(Outbound outbound, L listener) { |
| 157 | this.outbound = outbound; |
| 158 | this.statsTraceContext = outbound.getStatsTraceContext(); |
| 159 | this.listener = listener; |
| 160 | if (!isClosed()) { |
| 161 | onDeliveryState(State.INITIALIZED); |
| 162 | } |
| 163 | } |
| 164 | |
| 165 | final void unregister() { |
| 166 | transport.unregisterInbound(this); |
no test coverage detected