@@ -982,7 +982,7 @@ allowMethods(Pair.prototype, ["send", "receive"])
982982 * water mark for a connected {@link Subscriber}, then any messages that would
983983 * be sent to the subscriber in question shall instead be dropped until the mute
984984 * state ends. The {@link Writable.send}() method will never block.
985- *
985+ *
986986 * @includeExample examples/pub-sub/publisher.ts
987987 */
988988export class Publisher extends Socket {
@@ -1032,7 +1032,7 @@ allowMethods(Publisher.prototype, ["send"])
10321032 * {@link Publisher}. Initially a {@link Subscriber} is not subscribed to any
10331033 * messages. Use {@link Subscriber.subscribe}() to specify which messages to
10341034 * subscribe to. This socket cannot send messages.
1035- *
1035+ *
10361036 * @includeExample examples/pub-sub/subscriber.ts
10371037 */
10381038export class Subscriber extends Socket {
@@ -1139,7 +1139,7 @@ allowMethods(Subscriber.prototype, ["receive"])
11391139 * If no services are available, then any send operation on the socket shall
11401140 * block until at least one service becomes available. The REQ socket shall not
11411141 * discard messages.
1142- *
1142+ *
11431143 * @includeExample examples/req-rep/client.ts
11441144 */
11451145export class Request extends Socket {
@@ -1207,7 +1207,7 @@ allowMethods(Request.prototype, ["send", "receive"])
12071207 * among all clients, and each reply sent is routed to the client that issued
12081208 * the last request. If the original requester does not exist any more the reply
12091209 * is silently discarded.
1210- *
1210+ *
12111211 * @includeExample examples/req-rep/server.ts
12121212 */
12131213export class Reply extends Socket {
@@ -1240,7 +1240,7 @@ allowMethods(Reply.prototype, ["send", "receive"])
12401240 * When a {@link Dealer} is connected to a {@link Reply} socket, each message
12411241 * sent must consist of an empty message part, the delimiter, followed by one or
12421242 * more body parts.
1243- *
1243+ *
12441244 * @includeExample examples/queue/index.ts
12451245 * @includeExample examples/queue/queue.ts
12461246 */
@@ -1386,7 +1386,7 @@ allowMethods(Router.prototype, ["send", "receive"])
13861386 * A {@link Pull} socket is used by a pipeline node to receive messages from
13871387 * upstream pipeline nodes. Messages are fair-queued from among all connected
13881388 * upstream nodes. This socket cannot send messages.
1389- *
1389+ *
13901390 * @includeExample examples/push-pull/worker.ts
13911391 */
13921392export class Pull extends Socket {
@@ -1419,7 +1419,7 @@ allowMethods(Pull.prototype, ["receive"])
14191419 * at all, then {@link Writable.send}() will block until the mute state ends or
14201420 * at least one downstream node becomes available for sending; messages are not
14211421 * discarded.
1422- *
1422+ *
14231423 * @includeExample examples/push-pull/producer.ts
14241424 */
14251425export class Push extends Socket {
0 commit comments