Class: Hallon::Fifo

Inherits:
Object
  • Object
show all
Defined in:
lib/hallon-fifo/fifo.rb,
lib/hallon-fifo/version.rb

Constant Summary collapse

VERSION = 
"0.0.3"

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Fifo

Returns a new instance of Fifo.



8
9
10
11
12
13
14
15
16
 
# File 'lib/hallon-fifo/fifo.rb', line 8

def initialize
	@buffer = Array.new
	@playing, @stopped = false
	@buffer_size = 22050 # overridden by format=

	@output ||= "hallon-fifo.pcm"
	File.delete(@output) if File.exists?(@output)
	File.mkfifo(@output) # Will error if it's overwriting another file
end

Instance Attribute Details

#format ⇒ Object

Returns the value of attribute format.



6
7
8
 
# File 'lib/hallon-fifo/fifo.rb', line 6

def format
  @format
end

#output ⇒ Object

Returns the value of attribute output.



6
7
8
 
# File 'lib/hallon-fifo/fifo.rb', line 6

def output
  @output
end

Instance Method Details

#drops ⇒ Object 



31
32
33
34
35
 
# File 'lib/hallon-fifo/fifo.rb', line 31

def drops
	# This SHOULD return the number of times the queue "stuttered"
	# However, it ain't easy to do this with only knowledge of the fifo pipe.
	0
end

#pause ⇒ Object 



37
38
39
 
# File 'lib/hallon-fifo/fifo.rb', line 37

def pause
	@playing = false
end

#play ⇒ Object 



41
42
43
44
 
# File 'lib/hallon-fifo/fifo.rb', line 41

def play
	@playing = true
	@stopped = false
end

#reset ⇒ Object 



53
54
55
 
# File 'lib/hallon-fifo/fifo.rb', line 53

def reset
	self.output = @output
end

#stop ⇒ Object 



46
47
48
49
50
51
 
# File 'lib/hallon-fifo/fifo.rb', line 46

def stop
	@stopped = true
	@stream_thread.exit if @stream_thread

	@buffer.clear
end

#stream ⇒ Object

runs indefinitely



57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
 
# File 'lib/hallon-fifo/fifo.rb', line 57

def stream # runs indefinitely
	@stream_thread = Thread.new do
		queue = File.new(@output, "wb")

		loop do

			start = Time.now.to_f
			complete = start + 0.5

			# Get the next block from Spotify.
			audio_data = yield(@buffer_size)

			if audio_data.nil? # Audio format has changed, reset buffer.
				@buffer.clear
			else
				@buffer += audio_data
				begin
					queue.syswrite packed_samples(@buffer)
				rescue Errno::EPIPE
			        self.reset
				end
				@buffer.clear
			end

			ensure_playing

			finish = Time.now.to_f
			sleep complete - finish if finish < complete
		end
	end
end