Examples of PipedInputStream

com.aptana.shared_core.io.PipedInputStream
Special input stream we can write to and read() listeners will get it later. This class should be thread safe.
java.io.PipedInputStream
PipedInputStream is a class which receives information on a communications pipe. When two threads want to pass data back and forth, one creates a piped output stream and the other creates a piped input stream. @see PipedOutputStream
org.openmim.icq.util.joe.PipedInputStream
A piped input stream should be connected to a piped output stream; the piped input stream then provides whatever data bytes are written to the piped output stream. Typically, data is read from a PipedInputStream object by one thread and data is written to the corresponding PipedOutputStream by some other thread. Attempting to use both objects from a single thread is not recommended, as it may deadlock the thread. The piped input stream contains a buffer, decoupling read operations from write operations, within limits. @author James Gosling @version 1.28, 07/07/98 @see java.io.PipedOutputStream @since JDK1.0

Examples of com.aptana.shared_core.io.PipedInputStream

    public RhinoEclipseProcess(final int port,
            final int clientPort) {
        super();
        try {


            outputStream = new PipedInputStream();
            errorStream = new PipedInputStream();


            lock = new Object();


            thread = new Thread() {
                public void run() {

View Full Code Here

Examples of java.io.PipedInputStream

    private OutputStream pipeOut;


    public MessageBuilder(ServerInfo info, Logger logmon) throws IOException {
      super(name + ".MessageBuilder", logmon);
      this.servInfo = info;
      PipedInputStream is = new PipedInputStream();
      this.pipeIn = new NetworkInputStream(is);
      this.pipeOut = new PipedOutputStream(is);
    }

View Full Code Here

Examples of java.io.PipedInputStream

  }
  public void setExtOutputStream(OutputStream out, boolean dontclose){
    io.setExtOutputStream(out, dontclose);
  }
  public InputStream getInputStream() throws IOException {
    PipedInputStream in=
      new MyPipedInputStream(
                             32*1024  // this value should be customizable.
                             );
    io.setOutputStream(new PassiveOutputStream(in), false);
    return in;

View Full Code Here

Examples of java.io.PipedInputStream

                             );
    io.setOutputStream(new PassiveOutputStream(in), false);
    return in;
  }
  public InputStream getExtInputStream() throws IOException {
    PipedInputStream in=
      new MyPipedInputStream(
                             32*1024  // this value should be customizable.
                             );
    io.setExtOutputStream(new PassiveOutputStream(in), false);
    return in;

View Full Code Here

Examples of java.io.PipedInputStream

    
  {        
    String  get = "/download/" + getURL().toString().substring( 7 ) + " HTTP/1.0" + NL + NL;
    
    PipedOutputStream   pos = new PipedOutputStream();
    PipedInputStream   pis = new PipedInputStream();
    
    pis.connect( pos );
    
    input_stream  = pis;
    output_stream   = pos;
    
    MagnetURIHandler.getSingleton().process( get, new ByteArrayInputStream(new byte[0]), pos );

View Full Code Here

Examples of java.io.PipedInputStream

      loader.showError(err);
    }
  }


  public LogisimFile cloneLogisimFile(Loader newloader) {
    PipedInputStream reader = new PipedInputStream();
    PipedOutputStream writer = new PipedOutputStream();
    try {
      reader.connect(writer);
    } catch (IOException e) {
      newloader.showError(StringUtil.format(
        Strings.get("fileDuplicateError"), e.toString()));
      return null;
    }

View Full Code Here

Examples of java.io.PipedInputStream

        test(true);
        test(false);
    }


    private void test(final boolean commandLineArgs) throws IOException {
        testIn = new PipedInputStream();
        PipedOutputStream out = new PipedOutputStream(testIn);
        toolOut = new PrintStream(out, true);
        out = new PipedOutputStream();
        testOut = new PrintStream(out, true);
        toolIn = new PipedInputStream(out);
        Task task = new Task() {
            public void call() throws Exception {
                try {
                    Shell shell = new Shell();
                    shell.setIn(toolIn);

View Full Code Here

Examples of java.io.PipedInputStream

            }
            final JdbcConnection c = conn;
            // PipedReader / PipedWriter are a lot slower
            // than PipedInputStream / PipedOutputStream
            // (Sun/Oracle Java 1.6.0_20)
            final PipedInputStream in = new PipedInputStream();
            final Task task = new Task() {
                public void call() {
                    value = c.createClob(IOUtils.getReader(in), -1);
                }
            };

View Full Code Here

Examples of java.io.PipedInputStream

    public PipeURLConnection(URL url) {
        super(url);
    }


    public void connect() throws IOException {
        PipedInputStream pin = new BiggerPipeInputStream();
        pout = new PipedOutputStream(pin);
        response = PipeServer.startDispatch(url, this, pin, requestHeaders);
        connected = true;
    }

View Full Code Here

Examples of java.io.PipedInputStream

        return reqIn;
    }
    
    public OutputStream setResponse(Map<String, List<String>> h) throws IOException {
        synchronized (this) {
            PipedInputStream pin = new BiggerPipeInputStream();
            pout = new PipedOutputStream(pin);
            headers = h;
            in = pin;
            notifyAll();
            return pout;

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.