From 4c853dcc26bf8652bd8fe8644c99646b14ba042a Mon Sep 17 00:00:00 2001 From: Adi Putra <39253411+apolloid@users.noreply.github.com> Date: Sun, 29 Oct 2023 12:09:52 +0800 Subject: [PATCH 1/2] Update push-pull.md the original example which uses a pull socket to send a frame will return an error since the pull socket does not have such function --- docs/push-pull.md | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/docs/push-pull.md b/docs/push-pull.md index 9132f9631..c718355c2 100644 --- a/docs/push-pull.md +++ b/docs/push-pull.md @@ -35,14 +35,13 @@ namespace Ventilator // Sends batch of tasks to workers via that socket Console.WriteLine("====== VENTILATOR ======"); using (var sender = new PushSocket("@tcp://*:5557")) - using (var sink = new PullSocket(">tcp://localhost:5558")) { Console.WriteLine("Press enter when worker are ready"); Console.ReadLine(); //the first message it "0" and signals start of batch //see the Sink.csproj Program.cs file for where this is used Console.WriteLine("Sending start of batch to Sink"); - sink.SendFrame("0"); + sender.SendFrame("0"); Console.WriteLine("Sending tasks to workers"); //initialise random number generator Random rand = new Random(0); From 16e457343c944af69815796bf50152285a0f2876 Mon Sep 17 00:00:00 2001 From: Adi Putra <39253411+apolloid@users.noreply.github.com> Date: Tue, 31 Oct 2023 21:58:57 +0800 Subject: [PATCH 2/2] Update push-pull.md update to match with the zmq examples --- docs/push-pull.md | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/docs/push-pull.md b/docs/push-pull.md index c718355c2..858826c3b 100644 --- a/docs/push-pull.md +++ b/docs/push-pull.md @@ -35,13 +35,14 @@ namespace Ventilator // Sends batch of tasks to workers via that socket Console.WriteLine("====== VENTILATOR ======"); using (var sender = new PushSocket("@tcp://*:5557")) + using (var sink = new PushSocket(">tcp://localhost:5558")) { Console.WriteLine("Press enter when worker are ready"); Console.ReadLine(); //the first message it "0" and signals start of batch //see the Sink.csproj Program.cs file for where this is used Console.WriteLine("Sending start of batch to Sink"); - sender.SendFrame("0"); + sink.SendFrame("0"); Console.WriteLine("Sending tasks to workers"); //initialise random number generator Random rand = new Random(0);