Examples of java.io.PipedOutputStream.connect()

java.io.PipedOutputStream.connect()
Connects this piped output stream to a receiver. If this object is already connected to some other piped input stream, an IOException is thrown.
If snk is an unconnected piped input stream and src is an unconnected piped output stream, they may be connected by either the call:
```
 src.connect(snk)
```
or the call:
```
 snk.connect(src)
```
The two calls have the same effect. @param snk the piped input stream to connect to. @exception IOException if an I/O error occurs.

    FetchException ex = null; // set on failure
    try {
      if(returnBucket == null) finalResult = context.getBucketFactory(persistent()).makeBucket(maxLen);
      else finalResult = returnBucket;
      if(logMINOR) Logger.minor(this, "Writing final data to "+finalResult+" return bucket is "+returnBucket);
      dataOutput .connect(dataInput);
      result = new FetchResult(clientMetadata, finalResult);


      // Decompress
      if(decompressors != null) {
        if(logMINOR) Logger.minor(this, "Decompressing...");

View Full Code Here

      try {
        data = context.getBucketFactory(persistent).makeBucket(maxLen);
        output = data.getOutputStream();
        if(decompressors != null) {
          if(logMINOR) Logger.minor(this, "decompressing...");
          pipeOut.connect(pipeIn);
          DecompressorThreadManager decompressorManager =  new DecompressorThreadManager(pipeIn, decompressors, maxLen);
          pipeIn = decompressorManager.execute();
          ClientGetWorkerThread worker = new ClientGetWorkerThread(new BufferedInputStream(pipeIn), output, null, null, null, false, null, null, null, context.linkFilterExceptionProvider);
          worker.start();
          streamGenerator.writeTo(pipeOut, context);

View Full Code Here

      try {
        data = context.getBucketFactory(false).makeBucket(maxLen);
        output = data.getOutputStream();
        if(decompressors != null) {
          if(logMINOR) Logger.minor(this, "decompressing...");
          pipeOut.connect(pipeIn);
          DecompressorThreadManager decompressorManager =  new DecompressorThreadManager(pipeIn, decompressors, maxLen);
          pipeIn = decompressorManager.execute();
          ClientGetWorkerThread worker = new ClientGetWorkerThread(new BufferedInputStream(pipeIn), output, null, null, null, false, null, null, null, context.linkFilterExceptionProvider);
          worker.start();
          streamGenerator.writeTo(pipeOut, context);

View Full Code Here

       err = new PrintStream(console2);
       PipedOutputStream outPipe = new PipedOutputStream();
       inPipe = new PrintWriter(outPipe);
       in = new PipedInputStream();
       try {
           outPipe.connect(in);
       } catch(IOException exc) {
           exc.printStackTrace();
       }
       getDocument().addDocumentListener(this);
       addKeyListener(this);

View Full Code Here

  public void testWriteUTF8() throws IOException {
      PipedOutputStream out = null;
      closeStream(out);
      out = new PipedOutputStream();
      PipedInputStream snk = new PipedInputStream();
      out.connect(snk);
      System.out.println(snk.available());
      writeUTF8(out, "This is so good");
      System.out.println(snk.available());
      assertEquals(15, snk.available());
  }

View Full Code Here

  public void testWriteUTF8IgnoreExceptionOK() throws Exception {
      PipedOutputStream out = null;
      closeStream(out);
      out = new PipedOutputStream();
      PipedInputStream snk = new PipedInputStream();
      out.connect(snk);
      System.out.println(snk.available());
      writeUTF8IgnoreException(out, "This is so good");
      System.out.println(snk.available());
      assertEquals(15, snk.available());
  }

View Full Code Here

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.