DevWiki/websocket-sharp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Modify] Use it

Browse Source
This commit is contained in:
sta 2016-08-02 15:46:56 +09:00
parent 48e5a7cc5a
commit ef26fd2c7d
1 changed files with 15 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
Example1/AudioStreamer.cs
View File

@ -97,24 +97,13 @@ namespace Example1
private byte[] createBinaryMessage (float[,] bufferArray)
{
var msg = new List<byte> ();
var id = (uint) _id;
var chNum = bufferArray.GetLength (0);
var buffLen = bufferArray.GetLength (1);
msg.AddRange (id.ToByteArray (ByteOrder.Big));
msg.Add ((byte) chNum);
msg.AddRange (((uint) buffLen).ToByteArray (ByteOrder.Big));
chNum.Times (
i =>
buffLen.Times (
j => msg.AddRange (bufferArray[i, j].ToByteArray (ByteOrder.Big))
)
);
return msg.ToArray ();
return new BinaryMessage {
UserID = (uint) _id,
ChannelNumber = (byte) bufferArray.GetLength (0),
BufferLength = (uint) bufferArray.GetLength (1),
BufferArray = bufferArray
}
.ToArray ();
}
private string createTextMessage (string type, string message)
@ -130,19 +119,21 @@ namespace Example1
private void processBinaryMessage (byte[] data)
{
var msg = convertToAudioMessage (data);
if (msg.user_id == _id)
var msg = BinaryMessage.Parse (data);
var id = msg.UserID;
if (id == _id)
return;
Queue queue;
if (_audioBox.TryGetValue (msg.user_id, out queue)) {
queue.Enqueue (msg.buffer_array);
if (_audioBox.TryGetValue (id, out queue)) {
queue.Enqueue (msg.BufferArray);
return;
}
queue = Queue.Synchronized (new Queue ());
queue.Enqueue (msg.buffer_array);
_audioBox.Add (msg.user_id, queue);
queue.Enqueue (msg.BufferArray);
_audioBox.Add (id, queue);
}
private NotificationMessage processTextMessage (string data)