Drain will put a connection into a drain state. All subscriptions will immediately be put into a drain state. Upon completion, the publishers will be drained and can not publish any additional messages. Upon draining of the publishers, the connection will be closed. Use the ClosedCB() option to know
()
| 292 | // |
| 293 | // Deprecated: Encoded connections are no longer supported. |
| 294 | func (c *EncodedConn) Drain() error { |
| 295 | return c.Conn.Drain() |
| 296 | } |
| 297 | |
| 298 | // LastError reports the last error encountered via the Connection. |
| 299 | // |