pub async fn register_chainsync_initiator(
muxer: &StageRef<MuxMessage>,
peer: Peer,
conn_id: ConnectionId,
pipeline: StageRef<ChainSyncInitiatorMsg>,
eff: &Effects<ConnectionMessage>,
) -> StageRef<InitiatorMessage>pub async fn register_chainsync_initiator(
muxer: &StageRef<MuxMessage>,
peer: Peer,
conn_id: ConnectionId,
pipeline: StageRef<ChainSyncInitiatorMsg>,
eff: &Effects<ConnectionMessage>,
) -> StageRef<InitiatorMessage>