pub struct Connection<StepT: Clone + Eq + Debug + Deserialize + Serialize> {
pub participant_lookup: HashMap<ParticipantId, Rc<RefCell<Participant>>>,
pub out_blob_stream: Option<OutLogicFront>,
pub blob_stream_for_client_request: Option<u8>,
/* private fields */
}
Fields§
§participant_lookup: HashMap<ParticipantId, Rc<RefCell<Participant>>>
§out_blob_stream: Option<OutLogicFront>
§blob_stream_for_client_request: Option<u8>
Implementations§
source§impl<StepT: Clone + Eq + Debug + Deserialize + Serialize + Display> Connection<StepT>
impl<StepT: Clone + Eq + Debug + Deserialize + Serialize + Display> Connection<StepT>
pub fn new() -> Self
pub const fn phase(&self) -> &Phase
sourcepub fn on_connect(
&mut self,
connect_request: &ConnectRequest,
required_deterministic_simulation_version: &Version,
) -> Result<Vec<HostToClientCommands<Step<StepT>>>, HostLogicError>
pub fn on_connect( &mut self, connect_request: &ConnectRequest, required_deterministic_simulation_version: &Version, ) -> Result<Vec<HostToClientCommands<Step<StepT>>>, HostLogicError>
§Errors
HostLogicError
// TODO:
pub fn is_state_received_by_remote(&self) -> bool
Trait Implementations§
Auto Trait Implementations§
impl<StepT> Freeze for Connection<StepT>
impl<StepT> !RefUnwindSafe for Connection<StepT>
impl<StepT> !Send for Connection<StepT>
impl<StepT> !Sync for Connection<StepT>
impl<StepT> Unpin for Connection<StepT>where
StepT: Unpin,
impl<StepT> !UnwindSafe for Connection<StepT>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more