public void bytesRead(int bytes, int clientId)
	{
		if (this.clientId == clientId)
		{
			for (Iterator i = observers.iterator(); i.hasNext();)
			{
				ObservableStreamListener listener = (ObservableStreamListener) i
						.next();
				listener.bytesRead(bytes, clientId);
			}
		}
	}