This part of contract is just to let the guy know we are here.
338373
def announced(self, state, announcement):
        '''
        
        '''
        state.problem = state.factory(state.agent, **announcement.payload)
        state.medium.bid(message.Bid())
920323
def AddContract(self, contract):
        
        if not contract.PublicKeyHash.ToBytes() in self._keys.keys():
            raise Exception('Invalid operation - public key mismatch')

        self._contracts[contract.ScriptHash.ToBytes()] = contract
        if contract.ScriptHash in self._watch_only:
            self._watch_only.remove(contract.ScriptHash)
1267465
public final void notifyStateTransferEnd() {
      TotalOrderLatch block = stateTransferInProgress.getAndSet(null);
      if (block != null) {
         block.unBlock();
      }
      if (trace) {
         log.tracef("State Transfer finish. It will release %s", block);
      }
      totalOrderExecutor.checkForReadyTasks();
   }
889348
def deploy_token_contract(
            self,
            token_supply: int,
            token_decimals: int,
            token_name: str,
            token_symbol: str,
            token_type: str = 'CustomToken',
    ):
        """"""
        receipt = self.deploy(
            contract_name=token_type,
            args=[token_supply, token_decimals, token_name, token_symbol],
        )
        token_address = receipt['contractAddress']
        assert token_address and is_address(token_address)
        token_address = to_checksum_address(token_address)
        return {token_type: token_address}
825772
def announce(self, number):
        
        self.client.publish(self.keys.internal, self.keys.key(number))
        self.message('{} granted'.format(number))
1336814
public function isPending()
    {
        $status = $this->getStatus();
        return $status === self::STATUS_PROVISIONING || $status === self::STATUS_REQUESTED;
    }
471496
public String ok(){
        Map<String, String> notifyParams = new HashMap<>();
        notifyParams.put(WepayField.RETURN_CODE, "SUCCESS");
        notifyParams.put(WepayField.RETURN_MSG, "OK");
        return Maps.toXml(notifyParams);
    }
204538
def acknowledge_message(self, delivery_tag):
        
        logger.debug('Acknowledging message %s', delivery_tag)
        self._channel.basic_ack(delivery_tag)
185151
def on_welcome(self, connection, event):
        
        connection.join(self.channel, key=settings.IRC_CHANNEL_KEY or "")
845695
def deliver(message = nil, status = :success)
      return unless ENV[ci_computer.to_s]

      author, commit_message = last_git_log

      client.post(text: text(status, author, commit_message, message),
                  icon_emoji: ":#{ send(status.to_s + '_icon') }:")
    end
284594
@Override
    public void part(String reason) {
        Message partMessage = new Message(MessageType.PART, this.channelName, reason);
        this.client.getConnection().send(partMessage);
        this.joined = new CountDownLatch(1);
    }
946201
function Ready()
	{
		if (options.autoconnect)
		{
			// make a connection request immediately (optional)
			parent.GetPSN(true, function() {
				if (options.onReady) options.onReady();
				return;
			});
		}
		else
		{
			// just callback that we're ready (if anyone is listening)
			if (options.onReady) options.onReady();
			return;
		}
	}
1096908
public function onEmit()
    {
        if (!$this->duration) {
            $time = microtime(true);
            $this->duration = round($time - $this->start, 6);
        }
    }
879985
def _on_grant(self, grant):
        '''
        
        '''
        self.set_timeout(grant.expiration_time, ContractState.expired,
                         self._run_and_terminate, self.contractor.cancelled,
                         grant)

        self.grant = grant
        # this is necessary for nested contracts to work with handing
        # the messages over
        self.set_remote_id(grant.sender_id)
        self.update_manager_address(grant.reply_to)

        self.call_agent_side(self.contractor.granted, grant,
                             ensure_state=ContractState.granted)
1071424
function () {
  const oThis = this
  ;

  oThis.contractAddress = simpleTokenContractAddr;
  simpleTokenContractObj.options.address = oThis.contractAddress;
  //simpleTokenContractObj.setProvider(web3Provider.currentProvider);

  OpsManagedKlass.call(oThis, oThis.contractAddress, web3Provider, simpleTokenContractObj, VC_GAS_PRICE);
}
1098657
public Wepay init(){
        pays = new Pays(this);
        orders = new Orders(this);
        refunds = new Refunds(this);
        notifies = new Notifies(this);
        bills = new Bills(this);
        if (certs != null && !Strings.isNullOrEmpty(certPasswd)){
            sslSocketFactory = initSSLSocketFactory();
        }
        return this;
    }
333822
public Status withDescription(String description) {
    if (Objects.equal(this.description, description)) {
      return this;
    }
    return new Status(this.code, description, this.cause);
  }