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