Nomchy/discord.js
1
0
Fork 0
mirror of https://github.com/discordjs/discord.js.git synced 2026-03-15 02:53:31 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix some voice stuff

Browse Source
This commit is contained in:
Amish Shah
2016-08-25 14:49:10 +01:00
parent 7b2d76429f
commit 6d7e649bb1
4 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
docs/docs.json
View File

File diff suppressed because one or more lines are too long

2
src/client/voice/dispatcher/StreamDispatcher.js
View File

@@ -132,7 +132,7 @@ class StreamDispatcher extends EventEmitter {
data.length = 20; data.length = 20;
data.missed = 0; data.missed = 0;
data.startTime = Date.now(); data.startTime = Date.now();
this._send(); this.stream.once('readable', () => this._send());
} }
_pause(value) { _pause(value) {

8
src/client/voice/player/DefaultPlayer.js
View File

@@ -5,8 +5,12 @@ class DefaultPlayer extends BasePlayer {
playFile(file) { playFile(file) {
this._shutdown(); this._shutdown();
const fileStream = fs.createReadStream(file); return this.playStream(fs.createReadStream(file));
const pcmStream = this.convertStream(fileStream); }
playStream(stream) {
this._shutdown();
const pcmStream = this.convertStream(stream);
const dispatcher = this.playPCMStream(pcmStream); const dispatcher = this.playPCMStream(pcmStream);
return dispatcher; return dispatcher;
} }

5
test/random.js
View File

@@ -197,7 +197,7 @@ client.on('message', msg => {
} }
}); });
let disp; const ytdl = require('ytdl-core');
client.on('message', msg => { client.on('message', msg => {
if (msg.content.startsWith('/join')) { if (msg.content.startsWith('/join')) {
@@ -205,7 +205,10 @@ client.on('message', msg => {
msg.channel.guild.channels.get(chan).join() msg.channel.guild.channels.get(chan).join()
.then(conn => { .then(conn => {
msg.reply('done'); msg.reply('done');
const disp = conn.player.playStream(ytdl('https://www.youtube.com/watch?v=nbXgHAzUWB0', {filter : 'audioonly'}));
conn.player.on('debug', console.log); conn.player.on('debug', console.log);
conn.player.on('error', err => console.log(123, err));
disp.on('error', err => console.log(123, err));
}) })
.catch(console.log); .catch(console.log);
} }