 
 #-----------------------------------------------------------------------------------------------------------
 @new_sender = ( S ) ->
-  S.source    = new_pushable()
-  resend      = S.source.push.bind S.source
+  S.source    = new_push_source()
   on_stop     = PS.new_event_collector 'stop', -> help 'ok'
   pipeline    = []
   #.........................................................................................................

  new_start_event
  new_stop_event
  new_system_event
  recycling
  select
  select_all

  pipeline.push PS.$watch ( d ) -> help jr d
  # pipeline.push PS.$watch ( d ) -> help '> sink  ', rprx d unless is_meta d
  pipeline.push PS.$watch ( d ) -> if ( select d, '~', 'end' ) then S.source.end()
  pipeline.push $recycle S.source.push
  #.........................................................................................................
  pipeline.push on_stop.add PS.$drain()
  PS.pull pipeline...
