pingFrame := message{
		Op:         OpPing,
		DeadlineMS: uint32(connPingInterval.Milliseconds()),
		Payload:    make([]byte, pingMsg{}.Msgsize()),
	}

	defer ping.Stop()
	queue := make([][]byte, 0, maxMergeMessages)
	var queueSize int
	var buf bytes.Buffer
	var wsw wsWriter
	var lastSetDeadline time.Time

	// Helper to write everything in buf.