Merge pull request #9 from Kikobeats/next

Next

Author: Kikobeats

src/create.js

@@ -25,6 +25,16 @@ class LinkedList {
     this.head = this.head.next
     return data
   }
+
+  size () {
+    let count = 0
+    let current = this.head
+    while (current) {
+      count++
+      current = current.next
+    }
+    return count
+  }
 }
 
 module.exports = (slots = 1) => {
@@ -48,5 +58,7 @@ module.exports = (slots = 1) => {
 
   lock.isLocked = () => slots === 0
 
+  lock.awaiting = () => queue.size()
+
   return lock
 }

src/index.js

@@ -15,6 +15,7 @@ const withLock = opts => {
   }
 
   withLock.isLocked = lock.isLocked
+  withLock.awaiting = lock.awaiting
 
   return withLock
 }

test/index.js

@@ -0,0 +1,28 @@
+'use strict'
+
+const { createLock } = require('superlock')
+const test = require('ava')
+
+test('.awaiting', async t => {
+  const n = 100
+
+  const lock = createLock(1)
+
+  t.is(lock.isLocked(), false)
+
+  const collection = [...Array(n).keys()]
+
+  const promise = Promise.all(
+    collection.map(async index => {
+      const release = await lock()
+      release()
+      return index
+    })
+  )
+
+  t.is(lock.awaiting(), 99)
+
+  await promise
+
+  t.is(lock.awaiting(), 0)
+})