src/GcpBaseCall.php
protected function _rpcPreProcess($argument)
    {
        $this->affinity_key = null;
        if ($this->_affinity) {
            $command = $this->_affinity['command'];
            if ($command == self::BOUND || $command == self::UNBIND) {
                $this->affinity_key = $this->getAffinityKeyFromProto($argument);
            }
        }
        $this->channel_ref = $this->gcp_channel->getChannelRef($this->affinity_key);
        $this->channel_ref->activeStreamRefIncr();
        return $this->channel_ref;
    }
protected function _rpcPreProcess($argument)
    {
        $this->affinity_key = null;
        if ($this->_affinity) {
            $command = $this->_affinity['command'];
            if ($command == self::BOUND || $command == self::UNBIND) {
                $this->affinity_key = $this->getAffinityKeyFromProto($argument);
            }
        }
        $this->channel_ref = $this->gcp_channel->getChannelRef($this->affinity_key);
        $this->channel_ref->activeStreamRefIncr();
        return $this->channel_ref;
    }
protected function _rpcPreProcess ( $ argument ) { $ this -> affinity_key = null ; if ( $ this -> _affinity ) { $ command = $ this -> _affinity [ 'command' ] ; if ( $ command == self :: BOUND || $ command == self :: UNBIND ) { $ this -> affinity_key = $ this -> getAffinityKeyFromProto ( $ argument ) ; } } $ this -> channel_ref = $ this -> gcp_channel -> getChannelRef ( $ this -> affinity_key ) ; $ this -> channel_ref -> activeStreamRefIncr ( ) ; return $ this -> channel_ref ; }
Pick a ChannelRef from the channel pool based on the request and
the affinity config.

@param mixed $argument Requests.

@return ChannelRef
Pick a ChannelRef from the channel pool based on the request and the affinity config .