Merge pull request #574 from metadings/master

Update on C# Examples

examples/C#/psenvpub.cs

@@ -25,22 +25,32 @@ public static void PSEnvPub(string[] args)
 				publisher.Linger = TimeSpan.Zero;
 				publisher.Bind("tcp://*:5563");
 
+				int published = 0;
 				while (true)
 				{
 					// Write two messages, each with an envelope and content
+
 					using (var message = new ZMessage())
 					{
-						message.Add(new ZFrame("A"));
-						message.Add(new ZFrame("We don't want to see this"));
+						published++;
+						message.Add(new ZFrame(string.Format("A {0}", published)));
+						message.Add(new ZFrame(string.Format(" We don't like to see this.")));
+						Thread.Sleep(1000);
+
+						Console_WriteZMessage("Publishing ", message);
 						publisher.Send(message);
 					}
+
 					using (var message = new ZMessage())
 					{
-						message.Add(new ZFrame("B"));
-						message.Add(new ZFrame("We would like to see this"));
+						published++;
+						message.Add(new ZFrame(string.Format("B {0}", published)));
+						message.Add(new ZFrame(string.Format(" We do like to see this.")));
+						Thread.Sleep(1000);
+
+						Console_WriteZMessage("Publishing ", message);
 						publisher.Send(message);
 					}
-					Thread.Sleep(1000);
 				}
 			}
 		}

examples/C#/psenvsub.cs

@@ -25,17 +25,20 @@ public static void PSEnvSub(string[] args)
 				subscriber.Connect("tcp://127.0.0.1:5563");
 				subscriber.Subscribe("B");
 
+				int subscribed = 0;
 				while (true)
 				{
 					using (ZMessage message = subscriber.ReceiveMessage())
 					{
+						subscribed++;
+
 						// Read envelope with address
 						string address = message[0].ReadString();
 
 						// Read message contents
 						string contents = message[1].ReadString();
 
-						Console.WriteLine("[{0}] {1}", address, contents);
+						Console.WriteLine("{0}. [{1}] {2}", subscribed, address, contents);
 					}
 				}
 			}

examples/C#/suisnail.cs

@@ -120,7 +120,8 @@ public static void SuiSnail(string[] args)
 				subpipe.Frontend.ReceiveFrame();
 				pubpipe.Frontend.Send(new ZFrame("break"));
 
-				Thread.Sleep(5000);
+				// wait for the Thread (you'll see how fast it is)
+				pubpipe.Join(5000);
 			}
 		}
 	}