mth/ebiten
1
0
Fork 0
mirror of https://github.com/hajimehoshi/ebiten.git synced 2024-12-25 03:08:54 +01:00
Code Issues Packages Projects Releases Wiki Activity

audio: Refactoring

Browse Source
This commit is contained in:
Hajime Hoshi 2021-08-22 00:36:28 +09:00
parent 88da1bb23f
commit 7a5254f48f
2 changed files with 14 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
audio/internal/go2cpp/player_js.go
View File

@ -19,6 +19,8 @@ import (
"runtime"
"sync"
"syscall/js"
"github.com/hajimehoshi/ebiten/v2/audio/internal/readerdriver"
)
type Context struct {
@ -38,7 +40,7 @@ func NewContext(sampleRate int, channelNum, bitDepthInBytes int) *Context {
}
}
func (c *Context) NewPlayer(r io.Reader) *Player {
func (c *Context) NewPlayer(r io.Reader) readerdriver.Player {
cond := sync.NewCond(&sync.Mutex{})
onwritten := js.FuncOf(func(this js.Value, args []js.Value) interface{} {
cond.Signal()
@ -55,6 +57,16 @@ func (c *Context) NewPlayer(r io.Reader) *Player {
return p
}
func (c *Context) Suspend() error {
// Do nothing so far.
return nil
}
func (c *Context) Resume() error {
// Do nothing so far.
return nil
}
func (c *Context) oneBufferSize() int {
// TODO: This must be audio.oneBufferSize(p.context.sampleRate). Avoid the duplication.
return c.sampleRate * c.channelNum * c.bitDepthInBytes / 4

22
audio/player_js.go
View File

@ -15,7 +15,6 @@
package audio
import (
"io"
"syscall/js"
"github.com/hajimehoshi/ebiten/v2/audio/internal/go2cpp"
@ -26,27 +25,8 @@ func newContext(sampleRate, channelNum, bitDepthInBytes int) (context, chan stru
if js.Global().Get("go2cpp").Truthy() {
ready := make(chan struct{})
close(ready)
ctx := go2cpp.NewContext(sampleRate, channelNum, bitDepthInBytes)
return &go2cppDriverWrapper{ctx}, ready, nil
return go2cpp.NewContext(sampleRate, channelNum, bitDepthInBytes), ready, nil
}
return readerdriver.NewContext(sampleRate, channelNum, bitDepthInBytes)
}
type go2cppDriverWrapper struct {
c *go2cpp.Context
}
func (w *go2cppDriverWrapper) NewPlayer(r io.Reader) readerdriver.Player {
return w.c.NewPlayer(r)
}
func (w *go2cppDriverWrapper) Suspend() error {
// Do nothing so far.
return nil
}
func (w *go2cppDriverWrapper) Resume() error {
// Do nothing so far.
return nil
}