View Source Rclex.Subscriber (Rclex v0.9.0)
Defines control, start/stop, Rclex.SubLoop
functions.
Subscriber itself can be created on Node by calling below,
There are 4 GenServers including this module itself under the Node. They work together as shown below.
+-------------+
| Rclex.Node |
+-----+-------+
|
|
|
| +-------------------+ +-------------------+
+------Supervisor------------+ Rclex.Subscriber |------Supervisor------------+ Rclex.SubLoop |
| +--------^----------+ +--------+----------+
| | |
| | |
| | GenServer.cast to Rclex.Subscriber |
| | |
| +--------+----------+ |
| +-------+ Rclex.JobExecutor | GenServer.cast to JobQueue |
| | +--------^----------+ |
| | | |
+------Supervisor----+ | GenServer.cast to JobExecutor |
| | |
| +--------+----------+ |
+-------+ Rclex.JobQueue <-------------------------------------+
+-------------------+
- This module stored
call_back
to be executed. Rclex.SubLoop
triggers thecall_back
execution according to pushing message toRclex.JobQueue
.
Summary
Functions
Returns a specification to start this module under a supervisor.
subscriberを状態として持つ。start_subscribingをした際にcontextとcall_backを追加で状態として持つ。
Types
Functions
Returns a specification to start this module under a supervisor.
See Supervisor
.
subscriberを状態として持つ。start_subscribingをした際にcontextとcall_backを追加で状態として持つ。