MCPcopy
hub / github.com/nats-io/nats.go / flushReconnectPendingItems

Method flushReconnectPendingItems

nats.go:3133–3135  ·  view source on GitHub ↗

flushReconnectPendingItems will push the pending items that were gathered while we were in a RECONNECTING state to the socket.

()

Source from the content-addressed store, hash-verified

3131// flushReconnectPendingItems will push the pending items that were
3132// gathered while we were in a RECONNECTING state to the socket.
3133func (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.

Callers 1

doReconnectMethod · 0.95

Calls 1

flushPendingBufferMethod · 0.80

Tested by

no test coverage detected