 # suspend                   = require 'coffeenode-suspend'
 # step                      = suspend.step
 #...........................................................................................................
-# D                         = require 'pipedreams'
-# $                         = D.remit.bind D
-# $async                    = D.remit_async.bind D
 PS                        = require '../..'
 { $, $async, }            = PS
 assign                    = Object.assign

        send d
      return null
  #.........................................................................................................
  # pipeline.push PS.$watch ( d ) -> help '37744-3', jr d
  #.........................................................................................................
  pipeline.push do ->
    collector = []
    return $ 'null', ( d, send ) ->
      if d?
        if select_all d, '!', 'number'
          collector.push d.value
        else
          send d
      else
        send collector
  #.........................................................................................................
  pipeline.push PS.$watch ( d ) -> help '37744-4', jr d
  pipeline.push PS.$drain -> help 'ok'
  PS.pull pipeline...

  pipeline    = []
  #.........................................................................................................
  pipeline.push S.source
  pipeline.push PS.$watch ( d ) -> urge '37744-1', jr d
  pipeline.push PS2.$unwrap_recycled()
  # # pipeline.push PS.$delay 0.25
  # pipeline.push PS.$defer()
