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