       #.....................................................................................................
       try
         on_stop   = PS.new_event_collector 'stop', ->
-          send.done()
+          outer_send.done()
           help "(finished $call_stream #{method_name})"
         pipeline  = []
         pipeline.push await module[ method_name ] ctx, P...
-        pipeline.push PS.$watch ( line ) ->
+        #...................................................................................................
+        ### transform strings into text events ###
+        pipeline.push $ ( line, send ) ->
           if CND.isa_text line
             line = line + '\n' unless line.endsWith '\n'
             send [ '.', 'text', line, ( copy meta ), ]
           else
             send line
           return null
+        #...................................................................................................
+        pipeline.push $ ( event, send ) ->
+          outer_send event
+          send event
+        #...................................................................................................
         pipeline.push on_stop.add PS.$drain()
         PS.pull pipeline...
       #.....................................................................................................

        throw error
    #.......................................................................................................
    else
      send event
      send.done()
    #.......................................................................................................
    end() if end?
    return null



@$call_stream = ( S ) =>
  ### TAINT implicitly assumes return value will be lines of text ###
  # self = @
  return PIPEDREAMS.$async ( event, outer_send, outer_end ) =>
    #.......................................................................................................
    if event? and select event, '!', 'call_stream'
      { module, method_name, P, meta, locator, crumbs, }  = @_resolve_arguments S, event
