From a2402c32c0c6281de37a2df352aa9acaf1a92244 Mon Sep 17 00:00:00 2001
From: Hajime Hoshi <hajimehoshi@gmail.com>
Date: Mon, 27 Jun 2016 02:02:01 +0900
Subject: [PATCH] audio: Check the stream can be used or not

---
 audio/audio.go | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

diff --git a/audio/audio.go b/audio/audio.go
index df78e47d3..4ef797176 100644
--- a/audio/audio.go
+++ b/audio/audio.go
@@ -26,6 +26,7 @@
 package audio
 
 import (
+	"errors"
 	"io"
 	"runtime"
 	"sync"
@@ -136,6 +137,17 @@ func (p *players) playerCurrent(player *Player, sampleRate int) time.Duration {
 	return time.Duration(sample) * time.Second / time.Duration(sampleRate)
 }
 
+func (p *players) hasSource(src ReadSeekCloser) bool {
+	p.RLock()
+	defer p.RUnlock()
+	for player := range p.players {
+		if player.src == src {
+			return true
+		}
+	}
+	return false
+}
+
 // TODO: Enable to specify the format like Mono8?
 
 // A Context is a current state of audio.
@@ -259,8 +271,13 @@ type Player struct {
 // without a header (e.g. RIFF header).
 // The sample rate must be same as that of the audio context.
 //
+// Note that the given src can't be shared with other Players.
+//
 // This function is concurrent-safe.
 func NewPlayer(context *Context, src ReadSeekCloser) (*Player, error) {
+	if context.players.hasSource(src) {
+		return nil, errors.New("audio: src cannot be shared with another Player")
+	}
 	p := &Player{
 		players:    context.players,
 		src:        src,
@@ -280,6 +297,8 @@ func NewPlayer(context *Context, src ReadSeekCloser) (*Player, error) {
 
 // Close closes the stream. Ths source stream passed by NewPlayer will also be closed.
 //
+// After closing, the stream owned by the player will be usable to a new player again.
+//
 // This function is concurrent-safe.
 func (p *Player) Close() error {
 	p.players.removePlayer(p)