Skip to content
This repository was archived by the owner on Oct 30, 2024. It is now read-only.

Commit 9b01027

Browse files
repejotarepejota
committed
Better README and examples
1 parent 199c9cf commit 9b01027

5 files changed

Lines changed: 130 additions & 85 deletions

File tree

‎README.md‎

Lines changed: 65 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -60,30 +60,38 @@ $client->connect();
6060

6161
// Publish Subscribe
6262

63-
# Simple Subscriber
64-
$callback = function($message)
65-
{
66-
printf("Data: %s\r\n", $message->getBody());
67-
};
68-
$client->subscribe("foo", $callback);
69-
70-
# Simple Publisher
71-
$client->publish("foo", "foo bar");
72-
73-
# Wait for 1 message
63+
// Simple Subscriber.
64+
$client->subscribe(
65+
'foo',
66+
function ($message) {
67+
printf("Data: %s\r\n", $message->getBody());
68+
}
69+
);
70+
71+
// Simple Publisher.
72+
$client->publish('foo', 'Marty McFly');
73+
74+
// Wait for 1 message.
7475
$client->wait(1);
7576

7677
// Request Response
7778

78-
# Responding to requests
79-
$sid = $client->subscribe("sayhello", function ($message) {
80-
$message->reply("Reply: Hello, " . $message->getBody() . " !!!");
81-
});
82-
83-
# Request
84-
$client->request('sayhello', 'Marty McFly', function ($message) {
85-
echo $message->getBody();
86-
});
79+
// Responding to requests.
80+
$sid = $client->subscribe(
81+
'sayhello',
82+
function ($message) {
83+
$message->reply('Reply: Hello, '.$message->getBody().' !!!');
84+
}
85+
);
86+
87+
// Request.
88+
$client->request(
89+
'sayhello',
90+
'Marty McFly',
91+
function ($message) {
92+
echo $message->getBody();
93+
}
94+
);
8795
```
8896

8997
### Encoded Connections
@@ -96,30 +104,47 @@ $client->connect();
96104

97105
// Publish Subscribe
98106

99-
# Simple Subscriber
100-
$callback = function($payload)
101-
{
102-
printf("Data: %s\r\n", $payload->getBody()[1]);
103-
};
104-
$client->subscribe("foo", $callback);
105-
106-
# Simple Publisher
107-
$client->publish("foo", ["foo", "bar"]);
108-
109-
# Wait for 1 message
107+
// Simple Subscriber.
108+
$client->subscribe(
109+
'foo',
110+
function ($payload) {
111+
printf("Data: %s\r\n", $payload->getBody()[1]);
112+
}
113+
);
114+
115+
// Simple Publisher.
116+
$client->publish(
117+
'foo',
118+
[
119+
'Marty',
120+
'McFly',
121+
]
122+
);
123+
124+
// Wait for 1 message.
110125
$client->wait(1);
111126

112127
// Request Response
113128

114-
# Responding to requests
115-
$sid = $client->subscribe("sayhello", function ($message) {
116-
$message->reply("Reply: Hello, " . $message->getBody()[1] . " !!!");
117-
});
118-
119-
# Request
120-
$client->request('sayhello', ["foo", "McFly"], function ($message) {
121-
echo $message->getBody();
122-
});
129+
// Responding to requests.
130+
$sid = $client->subscribe(
131+
'sayhello',
132+
function ($message) {
133+
$message->reply('Reply: Hello, '.$message->getBody()[1].' !!!');
134+
}
135+
);
136+
137+
// Request.
138+
$client->request(
139+
'sayhello',
140+
[
141+
'Marty',
142+
'McFly',
143+
],
144+
function ($message) {
145+
echo $message->getBody();
146+
}
147+
);
123148
```
124149

125150

‎examples/pubsub/jsonencodedpubsub.php‎

Lines changed: 18 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -3,21 +3,26 @@
33

44
$encoder = new \Nats\Encoders\JSONEncoder();
55
$options = new \Nats\ConnectionOptions();
6-
$client = new \Nats\EncodedConnection($options, $encoder);
6+
$client = new \Nats\EncodedConnection($options, $encoder);
77
$client->connect();
88

9-
// Publish Subscribe
9+
// Publish Subscribe.
10+
// Simple Subscriber.
11+
$client->subscribe(
12+
'foo',
13+
function ($payload) {
14+
printf("Data: %s\r\n", $payload->getBody()[1]);
15+
}
16+
);
1017

11-
# Simple Subscriber
12-
$callback = function($payload)
13-
{
14-
printf("Data: %s\r\n", $payload->getBody()[1]);
15-
};
16-
$client->subscribe("foo", $callback);
18+
// Simple Publisher.
19+
$client->publish(
20+
'foo',
21+
[
22+
'Marty',
23+
'McFly',
24+
]
25+
);
1726

18-
# Simple Publisher
19-
$client->publish("foo", ["foo", "bar"]);
20-
21-
# Wait for 1 message
27+
// Wait for 1 message.
2228
$client->wait(1);
23-

‎examples/pubsub/pubsub.php‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -4,17 +4,17 @@
44
$client = new \Nats\Connection();
55
$client->connect();
66

7-
// Publish Subscribe
7+
// Publish Subscribe.
8+
// Simple Subscriber.
9+
$client->subscribe(
10+
'foo',
11+
function ($message) {
12+
printf("Data: %s\r\n", $message->getBody());
13+
}
14+
);
815

9-
# Simple Subscriber
10-
$callback = function($message)
11-
{
12-
printf("Data: %s\r\n", $message->getBody());
13-
};
14-
$client->subscribe("foo", $callback);
16+
// Simple Publisher.
17+
$client->publish('foo', 'Marty McFly');
1518

16-
# Simple Publisher
17-
$client->publish("foo", "foo bar");
18-
19-
# Wait for 1 message
19+
// Wait for 1 message.
2020
$client->wait(1);

‎examples/reqres/jsonencodedreqres.php‎

Lines changed: 20 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -3,17 +3,26 @@
33

44
$encoder = new \Nats\Encoders\JSONEncoder();
55
$options = new \Nats\ConnectionOptions();
6-
$client = new \Nats\EncodedConnection($options, $encoder);
6+
$client = new \Nats\EncodedConnection($options, $encoder);
77
$client->connect();
88

9-
// Request Response
9+
// Request Response.
10+
// Responding to requests.
11+
$sid = $client->subscribe(
12+
'sayhello',
13+
function ($message) {
14+
$message->reply('Reply: Hello, '.$message->getBody()[1].' !!!');
15+
}
16+
);
1017

11-
# Responding to requests
12-
$sid = $client->subscribe("sayhello", function ($message) {
13-
$message->reply("Reply: Hello, " . $message->getBody()[1] . " !!!");
14-
});
15-
16-
# Request
17-
$client->request('sayhello', ["foo", "McFly"], function ($message) {
18-
echo $message->getBody();
19-
});
18+
// Request.
19+
$client->request(
20+
'sayhello',
21+
[
22+
'Marty',
23+
'McFly',
24+
],
25+
function ($message) {
26+
echo $message->getBody();
27+
}
28+
);

‎examples/reqres/reqres.php‎

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -4,14 +4,20 @@
44
$client = new \Nats\Connection();
55
$client->connect();
66

7-
// Request Response
7+
// Request Response.
8+
// Responding to requests.
9+
$sid = $client->subscribe(
10+
'sayhello',
11+
function ($message) {
12+
$message->reply('Reply: Hello, '.$message->getBody().' !!!');
13+
}
14+
);
815

9-
# Responding to requests
10-
$sid = $client->subscribe("sayhello", function ($message) {
11-
$message->reply("Reply: Hello, " . $message->getBody() . " !!!");
12-
});
13-
14-
# Request
15-
$client->request('sayhello', 'Marty McFly', function ($message) {
16-
echo $message->getBody();
17-
});
16+
// Request.
17+
$client->request(
18+
'sayhello',
19+
'Marty McFly',
20+
function ($message) {
21+
echo $message->getBody();
22+
}
23+
);

0 commit comments

Comments
 (0)