mreceiverobserver.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.httptunnel.MLEYE;

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

public final 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 )
		{
		MLEYE.getInstance().sendDataToREye( buffer, dataSize, session ); 
		}
	}
else if( state == MByteReceiver.DISCONNECTED )
	{
	if( !session.isClosed() )
		{
		MLEYE.getInstance().endAllSession( session );
		}
	}
}
//--------------------------------------------------------------------------------------------
}