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