diff options
-rw-r--r-- | lib/dtas/player.rb | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/dtas/player.rb b/lib/dtas/player.rb index 37f2c96..61d29d2 100644 --- a/lib/dtas/player.rb +++ b/lib/dtas/player.rb @@ -282,7 +282,7 @@ class DTAS::Player # :nodoc: if deleted[0] warn("#{sink.name} died unexpectedly: #{status.inspect}") deleted.each { |t| drop_target(t) } - __current_drop unless @targets[0] + do_pause unless @targets[0] return # sink stays dead if it died unexpectedly end @@ -451,7 +451,7 @@ class DTAS::Player # :nodoc: # pull data from sink_buf into @targets, source feeds into sink_buf def sink_iter wait_iter = broadcast_iter(@sink_buf, @targets) - __current_drop if nil == wait_iter # sink error, stop source + do_pause if nil == wait_iter # sink error, stop source return wait_iter if @current # no source left to feed sink_buf, drain the remaining data |