anchor.diff:     #:multi
      #:exec
      #:discard
  -   ;; TODO: Publish/Subscribe
  +   ;; Publish/Subscribe
  +   #:pubsub-bad-event
  +   #:pubsub-bad-event-event
  +   #:pubsub-spam
  +   #:publish
  +   #:subscribe
  +   #:unsubscribe
  +   #:pubsub-dispatch
      ;; Persistence control commands
      #:save
      #:bgsave
  
positive.code:         (no-read (when (eq (car spec) :no-read) (pop spec)))
          (docstring (car (last spec)))
          (spec (butlast spec)))
      (push (symbol-name name) spec)
      (let ((inputs (cl:append (mapcan (lambda (x)
                                         (when (consp x)
                                           (list (if (eq (car x) 'list)
  
negative.code: (defun close-connection (connection)
    (when (connection-socket connection)
      (usocket:socket-close (connection-socket connection))
      (setf (connection-socket connection) nil)
      (clrhash (connection-channel-subscriptions connection))
      (clrhash (connection-pattern-subscriptions connection))))
  
  (defun connection-stream (connection)
    (usocket:socket-stream (connection-socket connection)))
  