flushReconnectPendingItems will push the pending items that were gathered while we were in a RECONNECTING state to the socket.
()
| 3131 | // flushReconnectPendingItems will push the pending items that were |
| 3132 | // gathered while we were in a RECONNECTING state to the socket. |
| 3133 | func (nc *Conn) flushReconnectPendingItems() error { |
| 3134 | return nc.bw.flushPendingBuffer() |
| 3135 | } |
| 3136 | |
| 3137 | // Stops the ping timer if set. |
| 3138 | // Connection lock is held on entry. |
no test coverage detected