       # mainstream.push PS.$watch ( d ) -> whisper '10191-6', 'confluence', jr d
       mainstream.push PS.$tee new_filtered_bysink 'number', numbers,  ( d ) -> CND.isa_number d
       mainstream.push PS.$tee new_filtered_bysink 'text',   texts,    ( d ) -> CND.isa_text d
-      mainstream.push PS.$tee new_filtered_bysink 'other',  null,     ( d ) -> ( not CND.isa_number d ) and ( not CND.isa_text d )
-      mainstream.push PS.$drain drainer
+      mainstream.push PS.$tee new_filtered_bysink 'other',  others,   ( d ) -> ( not CND.isa_number d ) and ( not CND.isa_text d )
+      mainstream.push PS.$drain ->
+        echo xrpr R
+        resolve R
       PS.pull mainstream...
       #...................................................................................................
       max_idx = ( Math.max probe[ 0 ].length, probe[ 1 ].length ) - 1
       for idx in [ 0 .. max_idx ]
-        source_1.send x if ( x = probe[ 0 ][ idx ] )?
-        source_2.send x if ( x = probe[ 1 ][ idx ] )?
+        source_1.send probe[ 0 ][ idx ] if idx < probe[ 0 ].length
+        source_2.send probe[ 1 ][ idx ] if idx < probe[ 1 ].length
       source_1.end()
       source_2.end()
   done()

  #.........................................................................................................
  done()
  return null


#-----------------------------------------------------------------------------------------------------------
@[ "new_merged_source 1" ] = ( T, done ) ->

{ jr
  is_empty }              = CND
defer                     = setImmediate
{ inspect, }              = require 'util'
xrpr                      = ( x ) -> inspect x, { colors: yes, breakLength: Infinity, maxArrayLength: Infinity, depth: Infinity, }

# https://pull-stream.github.io/#pull-through

