fn handle_new_call(
        &mut self,
        call: ClientEnd<CallMarker>,
        number: Number,
        state: CallState,
    ) -> CallIdx {
        let proxy = call.into_proxy().unwrap();
        let call = CallEntry::new(proxy.clone(), number.clone(), state);
        let index = self.current_calls.insert(call);
        let call_state = HangingGetStream::new(Box::new(move || Some(proxy.watch_state())));
        self.call_updates.insert(index, call_state.tagged(index).with_epitaph(index));
        self.terminated = false;
        index
    }
/// Insert a new call.
/// Returns the index of the call inserted.
Insert a new call.
Returns the index of the call inserted.
Insert a new call . Returns the index of the call inserted .
fn handle_new_call(
        &mut self,
        call: ClientEnd<CallMarker>,
        number: Number,
        state: CallState,
    ) -> CallIdx {
        let proxy = call.into_proxy().unwrap();
        let call = CallEntry::new(proxy.clone(), number.clone(), state);
        let index = self.current_calls.insert(call);
        let call_state = HangingGetStream::new(Box::new(move || Some(proxy.watch_state())));
        self.call_updates.insert(index, call_state.tagged(index).with_epitaph(index));
        self.terminated = false;
        index
    }
fn handle_new_call ( & mut self , call : ClientEnd < CallMarker > , number : Number , state : CallState , ) -> CallIdx { let proxy = call . into_proxy ( ) . unwrap ( ) ; let call = CallEntry :: new ( proxy . clone ( ) , number . clone ( ) , state ) ; let index = self . current_calls . insert ( call ) ; let call_state = HangingGetStream :: new ( Box :: new ( move | | Some ( proxy . watch_state ( ) ) ) ) ; self . call_updates . insert ( index , call_state . tagged ( index ) . with_epitaph ( index ) ) ; self . terminated = false ; index }
Insert a new call.
Insert a new call .
&mut self
call
ClientEnd<CallMarker>
number
Number
state
CallState
&mut self
call
ClientEnd<CallMarker>
number
Number
state
CallState