home *** CD-ROM | disk | FTP | other *** search
/ Symantec Visual Cafe for Java 2.5 / symantec-visual-cafe-2.5-database-dev-edition.iso / VCafe / main.bin / PipedWriter.java < prev    next >
Encoding:
Java Source  |  1997-05-20  |  3.1 KB  |  124 lines
  1. /*
  2.  * @(#)PipedWriter.java    1.5 97/01/27
  3.  * 
  4.  * Copyright (c) 1995, 1996 Sun Microsystems, Inc. All Rights Reserved.
  5.  * 
  6.  * This software is the confidential and proprietary information of Sun
  7.  * Microsystems, Inc. ("Confidential Information").  You shall not
  8.  * disclose such Confidential Information and shall use it only in
  9.  * accordance with the terms of the license agreement you entered into
  10.  * with Sun.
  11.  * 
  12.  * SUN MAKES NO REPRESENTATIONS OR WARRANTIES ABOUT THE SUITABILITY OF THE
  13.  * SOFTWARE, EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE
  14.  * IMPLIED WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
  15.  * PURPOSE, OR NON-INFRINGEMENT. SUN SHALL NOT BE LIABLE FOR ANY DAMAGES
  16.  * SUFFERED BY LICENSEE AS A RESULT OF USING, MODIFYING OR DISTRIBUTING
  17.  * THIS SOFTWARE OR ITS DERIVATIVES.
  18.  * 
  19.  * CopyrightVersion 1.1_beta
  20.  * 
  21.  */
  22.  
  23. package java.io;
  24.  
  25.  
  26. /**
  27.  * Piped character-output streams.
  28.  *
  29.  * @version     1.5, 97/01/27
  30.  * @author    Mark Reinhold
  31.  * @since    JDK1.1
  32.  */
  33.  
  34. public class PipedWriter extends Writer {
  35.  
  36.     PipedOutputStream byteSource;
  37.  
  38.     private byte buf[];        /* Conversion buffer */
  39.  
  40.     /**
  41.      * Create a writer that is not yet connected to a piped reader.
  42.      */
  43.     public PipedWriter() {
  44.     byteSource = new PipedOutputStream();
  45.     }
  46.  
  47.     /**
  48.      * Create a writer for the specified piped character-input stream.
  49.      */
  50.     public PipedWriter(PipedReader sink) throws IOException {
  51.     this();
  52.     connect(sink);
  53.     }
  54.  
  55.     /** Check to make sure that the stream has not been closed */
  56.     private void ensureOpen() throws IOException {
  57.     if (byteSource == null)
  58.         throw new IOException("Stream closed");
  59.     }
  60.  
  61.     /**
  62.      * Connect the specified piped reader to this writer.
  63.      */
  64.     public void connect(PipedReader sink) throws IOException {
  65.     synchronized (lock) {
  66.         ensureOpen();
  67.         byteSource.connect(sink.byteSink);
  68.     }
  69.     }
  70.  
  71.     /**
  72.      * Write a portion of an array of characters.
  73.      *
  74.      * @param  cbuf  Array of characters
  75.      * @param  off   Offset from which to start writing characters
  76.      * @param  len   Number of characters to write
  77.      *
  78.      * @exception  IOException  If an I/O error occurs
  79.      */
  80.     public void write(char cbuf[], int off, int len) throws IOException {
  81.     synchronized (lock) {
  82.         ensureOpen();
  83.  
  84.         int nb = len * 2;
  85.         if ((buf == null) || (buf.length < nb))
  86.         buf = new byte[nb];
  87.         for (int i = 0; i < nb; i += 2) {
  88.         char c = cbuf[off + (i >> 1)];
  89.         buf[i] = (byte) (c >> 8);
  90.         buf[i + 1] = (byte) c;
  91.         }
  92.  
  93.         byteSource.write(buf, 0, nb);
  94.     }
  95.     }
  96.  
  97.     /**
  98.      * Flush the stream.
  99.      *
  100.      * @exception  IOException  If an I/O error occurs
  101.      */
  102.     public void flush() throws IOException {
  103.     synchronized (lock) {
  104.         ensureOpen();
  105.         byteSource.flush();
  106.     }
  107.     }
  108.  
  109.     /**
  110.      * Close the stream.
  111.      *
  112.      * @exception  IOException  If an I/O error occurs
  113.      */
  114.     public void close() throws IOException {
  115.     synchronized (lock) {
  116.         if (byteSource == null)
  117.         return;
  118.         byteSource.close();
  119.         byteSource = null;
  120.     }
  121.     }
  122.  
  123. }
  124.