Clean up ns metadata, add windowing fn metadata

Author: KingMob

src/manifold/bus.clj

@@ -1,7 +1,6 @@
-(ns
-  ^{:author "Zach Tellman"
-    :doc    "An implementation of an event bus, where publishers and subscribers can interact via topics."}
-  manifold.bus
+(ns manifold.bus
+  {:author "Zach Tellman"
+   :doc    "An implementation of an event bus, where publishers and subscribers can interact via topics."}
   (:require
     [manifold
      [stream :as s]

src/manifold/deferred.clj

@@ -1,7 +1,6 @@
-(ns
-  ^{:author "Zach Tellman"
-    :doc    "Methods for creating, transforming, and interacting with asynchronous values."}
-  manifold.deferred
+(ns manifold.deferred
+  {:author "Zach Tellman"
+   :doc    "Methods for creating, transforming, and interacting with asynchronous values."}
   (:refer-clojure :exclude [realized? loop future])
   (:require
     [clojure.tools.logging :as log]

src/manifold/stream.clj

@@ -1,7 +1,6 @@
-(ns
-  ^{:author "Zach Tellman"
-    :doc    "Methods for creating, transforming, and interacting with asynchronous streams of values."}
-  manifold.stream
+(ns manifold.stream
+  {:author "Zach Tellman"
+   :doc    "Methods for creating, transforming, and interacting with asynchronous streams of values."}
   (:refer-clojure
     :exclude [map filter mapcat reductions reduce concat])
   (:require
@@ -1111,6 +1110,8 @@
 
    If `source` is supplied, inserts a dropping stream after `source`
    with the provided capacity."
+  {:author "Ryan Schmukler"
+   :added "0.3.0"}
   ([n]
    (let [in  (stream)
          out (dropping-stream n in)]
@@ -1136,6 +1137,8 @@
 
    If `source` is supplied, inserts a sliding stream after `source`
    with the provided capacity."
+  {:author "Ryan Schmukler"
+   :added "0.3.0"}
   ([n]
    (let [in  (stream)
          out (sliding-stream n in)]

src/manifold/time.clj

@@ -1,7 +1,6 @@
-(ns
-  ^{:author "Zach Tellman"
-    :doc    "This namespace contains methods for converting units of time, with milliseconds as the base representation, and for deferring execution of functions to some time in the future.  In practice, the methods here are not necessary to use Manifold effectively - `manifold.deferred/timeout` and `manifold.stream/periodically` are more directly useful - but they are available for anyone who should need them."}
-  manifold.time
+(ns manifold.time
+  {:author "Zach Tellman"
+   :doc    "This namespace contains methods for converting units of time, with milliseconds as the base representation, and for deferring execution of functions to some time in the future.  In practice, the methods here are not necessary to use Manifold effectively - `manifold.deferred/timeout` and `manifold.stream/periodically` are more directly useful - but they are available for anyone who should need them."}
   (:require
     [clojure.tools.logging :as log]
     [manifold.executor :as ex]