ioutiltest.java

一个java工作流引擎

package org.jbpm.util.io;

import java.io.*;
import junit.framework.*;

public class IoUtilTest extends TestCase {

  public void testTransfer() throws Exception {
    ByteArrayInputStream in = new ByteArrayInputStream( createBytes() );
    ByteArrayOutputStream out = new ByteArrayOutputStream();
    IoUtil.transfer( in, out );
    
    byte[] expectedBytes = createBytes();
    byte[] transferedBytes = out.toByteArray();
    
    assertEquals( expectedBytes.length, transferedBytes.length );
    
    for ( int i = 0; i < expectedBytes.length; i++ ) {
      assertEquals( expectedBytes[i], transferedBytes[i] );
    }
  }

  /**
   * creates 4KB of text bytes
   */
	private byte[] createBytes() {
    StringBuffer buffer = new StringBuffer(); 
		for ( int i = 0; i < 1024; i++ ) buffer.append("text"); 
    return buffer.toString().getBytes();
	}
}