class AudioStream::AudioObservableLambda
Public Class Methods
new(&block)
click to toggle source
# File lib/audio_stream/audio_observable_lambda.rb, line 7 def initialize(&block) @block = block end
Public Instance Methods
on_complete()
click to toggle source
# File lib/audio_stream/audio_observable_lambda.rb, line 16 def on_complete notify_complete end
on_next(input)
click to toggle source
# File lib/audio_stream/audio_observable_lambda.rb, line 11 def on_next(input) output = @block.call(input) notify_next(output) end