buildSrc/src/main/java/cc/squirreljme/plugin/util/LinePushOutputStream.java

   1 // -*- Mode: Java; indent-tabs-mode: t; tab-width: 4 -*-
   2 // ---------------------------------------------------------------------------
   3 // Multi-Phasic Applications: SquirrelJME
   4 //     Copyright (C) Stephanie Gawroriski <xer@multiphasicapps.net>
   5 // ---------------------------------------------------------------------------
   6 // SquirrelJME is under the GNU General Public License v3+, or later.
   7 // See license.mkd for licensing and copyright information.
   8 // ---------------------------------------------------------------------------
   9
  10 package cc.squirreljme.plugin.util;
  11
  12 import java.io.ByteArrayOutputStream;
  13 import java.io.IOException;
  14 import java.io.OutputStream;
  15
  16 /**
  17  * Output stream for pushing lines out.
  18  *
  19  * @since 2022/09/11
  20  */
  21 public abstract class LinePushOutputStream
  22         extends OutputStream
  23 {
  24         /** The working output buffer for logging. */
  25         private final ByteArrayOutputStream _buffer =
  26                 new ByteArrayOutputStream();
  27
  28         /**
  29          * Pushes the given string.
  30          *
  31          * @param __string The string to push.
  32          * @since 2022/09/11
  33          */
  34         protected abstract void push(String __string);
  35
  36         /**
  37          * {@inheritDoc}
  38          * @since 2022/07/01
  39          */
  40         @Override
  41         public final void write(int __b)
  42                 throws IOException
  43         {
  44                 synchronized (this)
  45                 {
  46                         if (__b == '\r' || __b == '\n')
  47                                 this.__push((byte)__b);
  48                         else
  49                                 this._buffer.write(__b);
  50                 }
  51         }
  52
  53         /**
  54          * {@inheritDoc}
  55          * @since 2022/07/01
  56          */
  57         @Override
  58         public final void write(byte[] __b)
  59                 throws NullPointerException
  60         {
  61                 if (__b == null)
  62                         throw new NullPointerException("NARG");
  63
  64                 this.write(__b, 0, __b.length);
  65         }
  66
  67         /**
  68          * {@inheritDoc}
  69          * @since 2022/07/01
  70          */
  71         @Override
  72         public final void write(byte[] __b, int __o, int __l)
  73                 throws IndexOutOfBoundsException, NullPointerException
  74         {
  75                 if (__b == null)
  76                         throw new NullPointerException("NARG");
  77                 if (__o < 0 || __l < 0 || (__o + __l) < 0 || (__o + __l) > __b.length)
  78                         throw new IndexOutOfBoundsException("IOOB");
  79
  80                 synchronized (this)
  81                 {
  82                         for (int i = 0; i < __l; i++)
  83                         {
  84                                 byte b = __b[__o + i];
  85
  86                                 if (b == '\r' || b == '\n')
  87                                         this.__push(b);
  88                                 else
  89                                         this._buffer.write(b);
  90                         }
  91                 }
  92         }
  93
  94         /**
  95          * Pushes the byte to the output.
  96          *
  97          * @param __b The byte which triggered the push.
  98          * @since 2022/07/01
  99          */
 100         private void __push(byte __b)
 101         {
 102                 // Ignore carriage returns
 103                 if (__b == '\r')
 104                         return;
 105
 106                 // Read string to print, wipe everything for the next round
 107                 ByteArrayOutputStream buffer = this._buffer;
 108                 String string = buffer.toString();
 109                 buffer.reset();
 110
 111                 // Inform subclass
 112                 this.push(string);
 113         }
 114 }