   "Remove any scheduled OSC messages from the run queue."
   []
   (snd "/clearSched"))
-
-(defn sync-all
-  "Wait until all asynchronous server operations have been completed."
-  []
-  @(recv "/synced"))
 
 ; The /done message just has a single argument:
 ; "/done" "s" <completed-command>


  (let [mesg-p (recv "/b_info")
        _   (snd "/b_query" (buffer-id buf))
        msg (await-promise mesg-p)
        [buf-id n-frames n-channels rate] (:args msg)]
    {:n-frames n-frames
     :n-channels n-channels


(defn await-promise
    "Read the reply received from the server, waiting for timeout ms if the message hasn't yet been received. Returns :timeout if a timeout occurs."
    ([prom] (await-promise prom REPLY-TIMEOUT))
    ([prom timeout]
       (try
         (.get (future @prom) timeout TimeUnit/MILLISECONDS)
         (catch TimeoutException t
           :timeout))))

(defn await-promise!
    "Read the reply received from the server, waiting for timeout ms if the message hasn't yet been received. Raises an exception if the message hasn't been received within timeout ms"
    ([prom] (await-promise prom REPLY-TIMEOUT))
    ([prom timeout]
       (.get (future @prom) timeout TimeUnit/MILLISECONDS)))

(defn- parse-status [args]
  (let [[_ ugens synths groups loaded avg peak nominal actual] args]
