Skip to main content

run_connection

Function run_connection 

Source
async fn run_connection<S>(
    socket: &mut ClientSocket<S>,
    state: &Arc<TransportState>,
    watching: &mut Watching,
    holds: &mut Holds<'_>,
    updates: &mut Option<(UnboundedReceiver<SeatUpdate>, bool)>,
    dictate: &mut Streaming,
    viewers: &mut Viewers,
    lanes: AnswerLanes<'_>,
    settings_push: SettingsPush,
    caller: Caller,
) -> Result<()>
where S: Stream<Item = Result<Message, Error>> + Sink<Message, Error = Error> + Unpin + Send,