mclientsenderobserver.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.httptunnel.MLEYE;

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

public class MClientSenderObserver
implements MObserver1
{
private MSender sender;
private MSession session;
//----------------------------------------------------------------------------------
public MClientSenderObserver( MSender in_sender, MSession in_session )
{
sender	= in_sender;
session	= in_session;
}
//----------------------------------------------------------------------------------
public void update()
{
int state = sender.getState();
if( state == MSender.SUCCESS )
	{
	try
		{
		MLEYE.getInstance().checkNextData( session );
		}
	catch( IOException  e )
		{
		MLEYE.getInstance().endLocalSession( session );
		}
	}
else
	{
	MLEYE.getInstance().endLocalSession( session );
	}
}
//----------------------------------------------------------------------------------
}