19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20 * or visit www.oracle.com if you need additional information or have any
21 * questions.
22 */
23
24 package jdk.testlibrary;
25
26 import java.io.BufferedInputStream;
27 import java.io.ByteArrayOutputStream;
28 import java.io.OutputStream;
29 import java.io.InputStream;
30 import java.io.IOException;
31 import java.util.HashSet;
32 import java.util.Set;
33 import java.util.concurrent.Future;
34 import java.util.concurrent.FutureTask;
35 import java.util.concurrent.atomic.AtomicBoolean;
36
37 /**
38 * @deprecated This class is deprecated. Use the one from
39 * {@code <root>/test/lib/share/classes/jdk/test/lib/process}
40 */
41 @Deprecated
42 public final class StreamPumper implements Runnable {
43
44 private static final int BUF_SIZE = 256;
45
46 /**
47 * Pump will be called by the StreamPumper to process the incoming data
48 */
49 abstract public static class Pump {
50 abstract void register(StreamPumper d);
51 }
52
53 /**
54 * OutputStream -> Pump adapter
55 */
56 final public static class StreamPump extends Pump {
57 private final OutputStream out;
58 public StreamPump(OutputStream out) {
59 this.out = out;
|
19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20 * or visit www.oracle.com if you need additional information or have any
21 * questions.
22 */
23
24 package jdk.testlibrary;
25
26 import java.io.BufferedInputStream;
27 import java.io.ByteArrayOutputStream;
28 import java.io.OutputStream;
29 import java.io.InputStream;
30 import java.io.IOException;
31 import java.util.HashSet;
32 import java.util.Set;
33 import java.util.concurrent.Future;
34 import java.util.concurrent.FutureTask;
35 import java.util.concurrent.atomic.AtomicBoolean;
36
37 /**
38 * @deprecated This class is deprecated. Use the one from
39 * {@code <root>/test/lib/jdk/test/lib/process}
40 */
41 @Deprecated
42 public final class StreamPumper implements Runnable {
43
44 private static final int BUF_SIZE = 256;
45
46 /**
47 * Pump will be called by the StreamPumper to process the incoming data
48 */
49 abstract public static class Pump {
50 abstract void register(StreamPumper d);
51 }
52
53 /**
54 * OutputStream -> Pump adapter
55 */
56 final public static class StreamPump extends Pump {
57 private final OutputStream out;
58 public StreamPump(OutputStream out) {
59 this.out = out;
|