Peer_trust.For_tests
val get_action_pipe : t -> (Actions.t * Network_peer.Peer.t) Async_kernel.Pipe.Reader.t