OMGeeky/tarpc
1
0
Fork 0
mirror of https://github.com/OMGeeky/tarpc.git synced 2025-12-31 16:44:31 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add documentation to PubSub example.

Browse Source
This commit is contained in:
Tim Kuehn
2020-07-29 18:05:35 -07:00
parent 6a01e32a2d
commit cf654549da
1 changed files with 25 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
tarpc/examples/pubsub.rs
View File

@@ -3,6 +3,31 @@
// Use of this source code is governed by an MIT-style
// license that can be found in the LICENSE file or at
// https://opensource.org/licenses/MIT.
/// - The PubSub server sets up TCP listeners on 2 ports, the "subscriber" port and the "publisher"
/// port. Because both publishers and subscribers initiate their connections to the PubSub
/// server, the server requires no prior knowledge of either publishers or subscribers.
///
/// - Subscribers connect to the server on the server's "subscriber" port. Once the connection is
/// established, the server acts as the client, sending messages to the subscribers via a
/// Subscriber service.
///
/// - Publishers connect to the server on the "publisher"port, and once connected, they send
/// messages to the server to be broadcast via a Publisher service.
///
/// Subscriber Publisher PubSub Server
/// T1 | | |
/// T2 |-----Connect------------------------------------------------------>|
/// T3 | | |
/// T4 | |-----Connect-------------------->|
/// T5 | | |
/// T6 | |-----Publish-------------------->|
/// T7 | | |
/// T8 |<------------------------------------------------------Receive-----|
/// T9 |-----(Receive OK)------------------------------------------------->|
/// T10 | | |
/// T11 | |<--------------(Publish OK)------|
use futures::{
future::{self, AbortHandle},
prelude::*,