mresponsereceiverobserver.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.httptunnel.MLEYE;

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

public final class MResponseReceiverObserver
implements MObserver1
{
private MResponseReceiver receiver;
//-----------------------------------------------------------------------------------------------------
public MResponseReceiverObserver( MResponseReceiver IN_receiver )
{
receiver = IN_receiver;
}
//-----------------------------------------------------------------------------------------------------
public final void update()
{
int state = receiver.getState();
if( state == MResponseReceiver.SUCCESS )
	{
	MHttpResponse response = receiver.getResponse();
	MLEYE.getInstance().sendDataToClient( response );
	}
else if( state == MResponseReceiver.ERROR )
	{
	try
		{
		MHttpResponse response = receiver.getResponse();
		System.err.write( response.getHeader() );
		MStreamUtil.connectStream( response.getBodyInputStream(), System.err );
		}
	catch( IOException e )
		{
		}
	//MLEYE.getInstance().exit();
	}
}
//-----------------------------------------------------------------------------------------------------
}