func (mb *tcpTransporter) flush(b []byte) (err error) {
	if err = mb.conn.SetReadDeadline(time.Now()); err != nil {
		return
	}
	// Timeout setting will be reset when reading
	if _, err = mb.conn.Read(b); err != nil {
		// Ignore timeout error
		if netError, ok := err.(net.Error); ok && netError.Timeout() {
			err = nil
		}
	}
	return
}
// flush flushes pending data in the connection,
// returns io.EOF if connection is closed.
flush flushes pending data in the connection,
returns io.EOF if connection is closed.
// flush flushes pending data in the connection // returns io . EOF if connection is closed .
func (mb *tcpTransporter) flush(b []byte) (err error) {
	if err = mb.conn.SetReadDeadline(time.Now()); err != nil {
		return
	}
	if _, err = mb.conn.Read(b); err != nil {
		if netError, ok := err.(net.Error); ok && netError.Timeout() {
			err = nil
		}
	}
	return
}
func ( mb * tcpTransporter ) flush ( b [ ] byte ) ( err error ) { if err = mb . conn . SetReadDeadline ( time . Now ( ) ) ; err != nil { return } if _ , err = mb . conn . Read ( b ) ; err != nil { if netError , ok := err . ( net . Error ) ; ok && netError . Timeout ( ) { err = nil } } return }
flush flushes pending data in the connection,
returns io.EOF if connection is closed.
flush flushes pending data in the connection returns io . EOF if connection is closed .
// Timeout setting will be reset when reading // Ignore timeout error