Struct holochain::prelude::mock_network::HolochainP2pMockChannel

pub struct HolochainP2pMockChannel { /* private fields */ }

A channel between the simulated network and the set of real holochain nodes.

Implementations

impl HolochainP2pMockChannel

pub fn channel( peer_data: Vec<AgentInfoSigned, Global>, buffer: usize, scenario: MockScenario ) -> (Sender<KitsuneMock>, ToKitsuneMockChannelRx, HolochainP2pMockChannel)

Create a new mock simulated network channel. The peer data is the simulated nodes. The buffer is the amount of messages that can be buffered. The scenario sets up the why this simulated network will behave.

pub async fn next( &mut self ) -> impl Future<Output = Option<(AddressedHolochainP2pMockMsg, Option<HolochainP2pMockRespond>)>>

Await the next message from the real nodes. Note that all messages are routed through this call so blocking on the loop that calls next will slow down all simulated node response times. This is probably not what you want.

pub async fn send( &self, msg: AddressedHolochainP2pMockMsg ) -> impl Future<Output = Option<HolochainP2pMockMsg>>

Send a notify or request from an addressed simulated agent. If this is a request you will get back the response.