Open the channel for communication.
559164
def open(self):
        '''
        
        '''
        args = Writer()
        args.write_shortstr('')
        self.send_frame(MethodFrame(self.channel_id, 20, 10, args))
        self.channel.add_synchronous_cb(self._recv_open_ok)
532471
def create_channel(self, channel):
        

        data = {'channels': channel}
        return super(ApiInterfaceRequest, self).post('api/v3/channel/', data)
59292
def kick(self, channel, target, reason=None):
        """"""
        if reason:
            target += ' :' + reason
        self.send_line('KICK %s %s' % (channel, target), nowait=True)
1317990
def kick(self, channel, nick, comment=""):
        """"""
        self.send_items('KICK', channel, nick, comment and ':' + comment)
283770
function Channel(url, protocol) {
  events.EventEmitter.call(this)

  this._url      = url
  this._protocol = protocol
}
1288782
def send_signal(self, request, response, forum):
        
        self.view_signal.send(
            sender=self, forum=forum, user=request.user, request=request, response=response,
        )
513727
def join(self, new_channel, nick, pwd=None):
        
        self._send_packet({"cmd": "join", "channel": new_channel,
                           "nick": self._format_nick(nick, pwd)})
210890
def _on_connection_open(self, connection):
        
        _log.info("Successfully opened connection to %s", connection.params.host)
        self._channel = connection.channel(on_open_callback=self._on_channel_open)
1089462
def emit(self, *args, **kwargs):
        '''
        
        '''
        self._messanger.send(self, *args, **kwargs)
146782
def enter(self):
        """"""
        self._communication.send(StartRequest,
                                 self._communication.left_end_needle,
                                 self._communication.right_end_needle)
1131361
def open(self):
        
        self._connection = \
          amqp.Connection(host='%s:%s' % (self.hostname, self.port),
                          userid=self.username, password=self.password,
                          virtual_host=self.virtual_host, insist=False)
        self.channel = self._connection.channel()
933938
def on_connect(client):
    
    print "++ Opened connection to %s" % client.addrport()
    broadcast('%s joins the conversation.\n' % client.addrport() )
    CLIENT_LIST.append(client)
    client.send("Welcome to the Chat Server, %s.\n" % client.addrport() )
892720
def channels_create(self, name, **kwargs):
        """"""
        return self.__call_api_post('channels.create', name=name, kwargs=kwargs)
1308221
def broadcast(self, channel, event, data):
        """"""
        payload = self._server.serialize_event(event, data)
        for socket_id in self.subscriptions.get(channel, ()):
            rv = self._server.sockets.get(socket_id)
            if rv is not None:
                rv.socket.send(payload)
836622
def channel(self) -> Iterator[amqp.Channel]:
        """"""
        with self.connection() as conn:
            ch = conn.channel()
            logger.info('Opened new channel')
            with _safe_close(ch):
                yield ch
1201126
async def join(self, ctx, *, channel: discord.VoiceChannel):
        """"""

        if ctx.voice_client is not None:
            return await ctx.voice_client.move_to(channel)

        await channel.connect()
962084
def listen(self):
        ''''''
        for message in Listener.listen(self):
            logger.debug('Message: %s', message)
            # Strip off the 'namespace' from the channel
            channel = message['channel'][len(self.namespace):]
            func = self._callbacks.get(channel)
            if func:
                func(message['data'])