mreceiverobserver.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.MTCPC;

import net.jumperz.util.*;
import net.jumperz.net.*;

public class MReceiverObserver
implements MObserver1
{
private MStringReceiver Receiver;
private MTCPC TCPC;
//----------------------------------------------------------------------
public MReceiverObserver( MStringReceiver IN_Receiver, MTCPC IN_TCPC )
{
Receiver = IN_Receiver;
TCPC = IN_TCPC;
}
//----------------------------------------------------------------------
public void update()
{
int state = Receiver.getState();
if( state == MStringReceiver.CONNECTED )
	{
	String str = Receiver.getBuffer();
	if( str != null )
		{
		TCPC.updateText( Receiver.getBuffer() );
		}
	}
else if( state == MStringReceiver.DISCONNECTED )
	{
	TCPC.stopSession();
	}
}
//----------------------------------------------------------------------
}