# hosts/subscriber.h
## `Subscriber::Subscriber`
`Subscriber(Simulator *sim, NodeId id, Publisher *publisher, std::unique_ptr<SubBasePolicy> policy, Time mgmt_latency, Time heartbeat_period) noexcept`
## `Subscriber::recv_flow`
`void recv_flow(NodeId src, FlowId flow, FlowPriority prio, Bytes flow_size) override`
## `Subscriber::recv_frame`
`void recv_frame(const Packet &frame) override`
## `Subscriber::recv_mgmt_msg`
`virtual void recv_mgmt_msg(MgmtMsgPtr msg) noexcept override`
## `Subscriber::set_publisher`
`void set_publisher(Publisher *p) noexcept`
## `Subscriber::set_status`
`void set_status(NodeStatus s) noexcept`
## `dofs::on_heartbeat_timer`
`void on_heartbeat_timer() noexcept;`
## `dofs::schedule_next_heartbeat`
`void schedule_next_heartbeat(Time delay) noexcept;`
## `dofs::send_job_finished`
`void send_job_finished(FlowId flow) noexcept;`