[Modify] Polish it

This commit is contained in:
sta 2015-11-15 15:36:01 +09:00
parent 5eff459c44
commit b8bc01d100
2 changed files with 15 additions and 16 deletions

View File

@ -54,9 +54,7 @@ namespace Example
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 ()

View File

@ -9,15 +9,15 @@ namespace Example
{ {
public static void Main (string[] args) public static void Main (string[] args)
{ {
/* Create a new instance of the WebSocket class. // Create a new instance of the WebSocket class.
* //
* The WebSocket class inherits the System.IDisposable interface, so you can use the using // The WebSocket class inherits the System.IDisposable interface, so you can
* statement. And the WebSocket connection will be closed with close status 1001 (going away) // use the using statement. And the WebSocket connection will be closed with
* when the control leaves the using block. // close status 1001 (going away) when the control leaves the using block.
* //
* If you would like to connect to the server with the secure connection, you should create // If you would like to connect to the server with the secure connection,
* the instance with the wss scheme WebSocket URL. // you should create the instance with the wss scheme WebSocket URL.
*/
using (var nf = new Notifier ()) using (var nf = new Notifier ())
using (var ws = new WebSocket ("ws://echo.websocket.org")) using (var ws = new WebSocket ("ws://echo.websocket.org"))
//using (var ws = new WebSocket ("wss://echo.websocket.org")) //using (var ws = new WebSocket ("wss://echo.websocket.org"))
@ -28,14 +28,15 @@ namespace Example
//using (var ws = new WebSocket ("ws://localhost:4649/Chat?name=nobita")) //using (var ws = new WebSocket ("ws://localhost:4649/Chat?name=nobita"))
//using (var ws = new WebSocket ("wss://localhost:4649/Chat")) //using (var ws = new WebSocket ("wss://localhost:4649/Chat"))
{ {
// To set the WebSocket events. // Set the WebSocket events.
ws.OnOpen += (sender, e) => ws.Send ("Hi, there!"); ws.OnOpen += (sender, e) => ws.Send ("Hi, there!");
ws.OnMessage += (sender, e) => ws.OnMessage += (sender, e) =>
nf.Notify ( nf.Notify (
new NotificationMessage { new NotificationMessage {
Summary = "WebSocket Message", Summary = "WebSocket Message",
Body = e.Type != Opcode.Ping ? e.Data : "Received a Ping.", Body = !e.IsPing ? e.Data : "Received a ping.",
Icon = "notification-message-im" Icon = "notification-message-im"
}); });
@ -62,7 +63,7 @@ namespace Example
// To change the wait time for the response to the Ping or Close. // To change the wait time for the response to the Ping or Close.
ws.WaitTime = TimeSpan.FromSeconds (10); ws.WaitTime = TimeSpan.FromSeconds (10);
// To emit a WebSocket.OnMessage event when receives a Ping. // To emit a WebSocket.OnMessage event when receives a ping.
ws.EmitOnPing = true; ws.EmitOnPing = true;
#endif #endif
// To enable the Per-message Compression extension. // To enable the Per-message Compression extension.
@ -81,7 +82,7 @@ namespace Example
}; };
*/ */
// To set the credentials for the HTTP Authentication (Basic/Digest). // To send the credentials for the HTTP Authentication (Basic/Digest).
//ws.SetCredentials ("nobita", "password", false); //ws.SetCredentials ("nobita", "password", false);
// To send the Origin header. // To send the Origin header.