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

Method Flush

nats.go:5855–5857  ·  view source on GitHub ↗

Flush will perform a round trip to the server and return when it receives the internal reply.

()

Source from the content-addressed store, hash-verified

5853// Flush will perform a round trip to the server and return when it
5854// receives the internal reply.
5855func (nc *Conn) Flush() error {
5856 return nc.FlushTimeout(10 * time.Second)
5857}
5858
5859// Buffered will return the number of bytes buffered to be sent to the server.
5860// FIXME(dlc) take into account disconnected state.

Callers 15

doReconnectMethod · 0.95
checkDrainedMethod · 0.95
TestNilConnectionFunction · 0.95
WriteMethod · 0.45
ExampleConn_FlushFunction · 0.45
TestClientTLSConfigFunction · 0.45
TestClientCertificateFunction · 0.45
TestClosedConnectionsFunction · 0.45
TestCallbacksOrderFunction · 0.45

Calls 1

FlushTimeoutMethod · 0.95

Tested by 15

TestNilConnectionFunction · 0.76
ExampleConn_FlushFunction · 0.36
TestClientTLSConfigFunction · 0.36
TestClientCertificateFunction · 0.36
TestClosedConnectionsFunction · 0.36
TestCallbacksOrderFunction · 0.36
TestFlushReleaseOnCloseFunction · 0.36
TestBarrierFunction · 0.36
TestWSControlFramesFunction · 0.36