mserversenderobserver.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.httptunnel.MREYE;

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

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