Codebase list core-async-clojure / 66303a4 src / test / cljs / cljs / core / async / buffer_tests.cljs
66303a4

Tree @66303a4 (Download .tar.gz)

buffer_tests.cljs @66303a4 — raw · history · blame 

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
;;   Copyright (c) Rich Hickey and contributors. All rights reserved.
;;   The use and distribution terms for this software are covered by the
;;   Eclipse Public License 1.0 (http://opensource.org/licenses/eclipse-1.0.php)
;;   which can be found in the file epl-v10.html at the root of this distribution.
;;   By using this software in any fashion, you are agreeing to be bound by
;;   the terms of this license.
;;   You must not remove this notice, or any other, from this software.

(ns cljs.core.async.buffer-tests
  (:require-macros [cljs.core.async.macros :as m :refer [go]])
  (:require [cljs.core.async
             :refer [unblocking-buffer? buffer dropping-buffer sliding-buffer
                     put! take! chan close!]]
            [cljs.core.async.impl.dispatch :as dispatch]
            [cljs.core.async.impl.buffers :as buff :refer [promise-buffer]]
            [cljs.core.async.impl.protocols
             :refer [full? add! remove! close-buf!]]
            [cljs.core.async.test-helpers :refer-macros [throws?]]
            [cljs.test :refer-macros [deftest testing is]]))

(deftest unblocking-buffer-tests
  (testing "buffers"
    (is (not (unblocking-buffer? (buffer 1))))
    (is (unblocking-buffer? (dropping-buffer 1)))
    (is (unblocking-buffer? (sliding-buffer 1)))))

(deftest buffer-tests
  (testing "fixed-buffer"
    (let [fb (buffer 2)]
      (is (= 0 (count fb)))

      (add! fb :1)
      (is (= 1 (count fb)))

      (add! fb :2)
      (is (= 2 (count fb)))

      (is (full? fb))
      #_(assert (throws? (add! fb :3)))

      ; already overflown
      (add! fb :3)
      (is (= 3 (count fb)))
      (is (full? fb))

      (is (= :1 (remove! fb)))
      (is (= 2 (count fb)))
      (is (full? fb))

      (is (= :2 (remove! fb)))
      (is (= 1 (count fb)))
      (is (not (full? fb)))

      (is (= :3 (remove! fb)))
      (is (= 0 (count fb)))
      #_(is (helpers/throws? (remove! fb)))))

  (testing "dropping-buffer"
    (let [fb (dropping-buffer 2)]
      (is (= 0 (count fb)))

      (add! fb :1)
      (is (= 1 (count fb)))

      (add! fb :2)
      (is (= 2 (count fb)))

      (is (not (full? fb)))
      (add! fb :3)

      (is (= 2 (count fb)))

      (is (= :1 (remove! fb)))
      (is (not (full? fb)))

      (is (= 1 (count fb)))
      (is (= :2 (remove! fb)))

      (is (= 0 (count fb)))
      #_(is (throws? (remove! fb)))))

  (testing "sliding-buffer"
    (let [fb (sliding-buffer 2)]
      (is (= 0 (count fb)))

      (add! fb :1)
      (is (= 1 (count fb)))

      (add! fb :2)
      (is (= 2 (count fb)))

      (is (not (full? fb)))
      (add! fb :3)

      (is (= 2 (count fb)))

      (is (= :2 (remove! fb)))
      (is (not (full? fb)))

      (is (= 1 (count fb)))
      (is (= :3 (remove! fb)))

      (is (= 0 (count fb)))
      #_(is (throws? (remove! fb))))))

(deftest promise-buffer-tests
  (let [pb (promise-buffer)]
    (is (= 0 (count pb)))

    (add! pb :1)
    (is (= 1 (count pb)))

    (add! pb :2)
    (is (= 1 (count pb)))

    (is (not (full? pb)))
    (is (not (throws? (add! pb :3))))
    (is (= 1 (count pb)))

    (is (= :1 (remove! pb)))
    (is (not (full? pb)))

    (is (= 1 (count pb)))
    (is (= :1 (remove! pb)))

    (is (= nil (close-buf! pb)))
    (is (= :1 (remove! pb)))))