mreceiverobserver.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.httptunnel.MREYE;

import net.jumperz.util.*;
import net.jumperz.app.httptunnel.*;

public class MReceiverObserver
implements MObserver1
{
private MByteReceiver receiver;
private MSession session;
//----------------------------------------------------------------------------------
public MReceiverObserver( MByteReceiver in_receiver, MSession in_session )
{
receiver = in_receiver;
session  = in_session;
}
//----------------------------------------------------------------------------------
public final void update()
{
int state = receiver.getState();
if( state == MByteReceiver.CONNECTED )
	{
	int dataSize  = receiver.getDataSize();
	byte[] buffer = receiver.getBuffer();
	if( buffer != null )
		{
		MREYE.getInstance().createResponse( buffer, dataSize, session );
		}
	}
else if( state == MByteReceiver.DISCONNECTED )
	{
	if( !session.isClosed() )
		{
		MREYE.getInstance().endSession( session );
		}
	}
}
//----------------------------------------------------------------------------------
}