   
   flush: ->
     subject = null for subject in @queue
+    @current = null
     @queue = []
     
   next: ->
-    subject = @queue.shift()
+    @current = @queue.shift()
     @fetch() if @queue.length < 2
-    subject
+    @current
 
 module.exports = Subjects
class Subjects
  queue: []
  api: null
  query:
    sort: 'queued'
    page_size: "30"

    @query.workflow_id = @project?.links.workflows[0]
    @query.subject_set_id = @subject_set_id
    
  fetch: ->
    return Promise.resolve [] unless @query.workflow_id? && @query.subject_set_id?
    @api.type('subjects')
