[Modify] Polish it
This commit is contained in:
parent
b8bc01d100
commit
5cc462ac25
@ -39,7 +39,7 @@ namespace Example1
|
|||||||
_websocket.Send (createTextMessage ("connection", String.Empty));
|
_websocket.Send (createTextMessage ("connection", String.Empty));
|
||||||
|
|
||||||
_websocket.OnMessage += (sender, e) => {
|
_websocket.OnMessage += (sender, e) => {
|
||||||
if (e.Type == Opcode.Text) {
|
if (e.IsText) {
|
||||||
_notifier.Notify (convertTextMessage (e.Data));
|
_notifier.Notify (convertTextMessage (e.Data));
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
|
@ -54,9 +54,7 @@ namespace Example1
|
|||||||
private NotificationMessage dequeue ()
|
private NotificationMessage dequeue ()
|
||||||
{
|
{
|
||||||
lock (_sync)
|
lock (_sync)
|
||||||
return _queue.Count > 0
|
return _queue.Count > 0 ? _queue.Dequeue () : null;
|
||||||
? _queue.Dequeue ()
|
|
||||||
: null;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public void Close ()
|
public void Close ()
|
||||||
|
Loading…
Reference in New Issue
Block a user