39 lines
742 B
Python
39 lines
742 B
Python
|
class stream():
|
||
|
|
def __init__(self, name):
|
||
|
|
"""
|
||
|
|
Initialize a stream object
|
||
|
|
|
||
|
|
:param name: stream name
|
||
|
|
"""
|
||
|
|
self.name = name
|
||
|
|
self.clients = []
|
||
|
|
|
||
|
|
def addClient(self, client):
|
||
|
|
"""
|
||
|
|
Add a client to this stream if not already in
|
||
|
|
|
||
|
|
:param client: client (osuToken) object
|
||
|
|
:return:
|
||
|
|
"""
|
||
|
|
if client not in self.clients:
|
||
|
|
self.clients.append(client)
|
||
|
|
|
||
|
|
def removeClient(self, client):
|
||
|
|
"""
|
||
|
|
Remove a client from this stream if in
|
||
|
|
|
||
|
|
:param client: client (osuToken) object
|
||
|
|
:return:
|
||
|
|
"""
|
||
|
|
if client in self.clients:
|
||
|
|
self.clients.remove(client)
|
||
|
|
|
||
|
|
def broadcast(self, data):
|
||
|
|
"""
|
||
|
|
Send some data to all clients connected to this stream
|
||
|
|
|
||
|
|
:param data: data to send
|
||
|
|
:return:
|
||
|
|
"""
|
||
|
|
for i in self.clients:
|
||
|
|
i.enqueue(data)
|