Method: AudioStream::AudioObservableLambda#on_next

Defined in:
lib/audio_stream/audio_observable_lambda.rb

#on_next(input) ⇒ Object 



11
12
13
14
 
# File 'lib/audio_stream/audio_observable_lambda.rb', line 11

def on_next(input)
  output = @block.call(input)
  notify_next(output)
end