Added buffering hints to all transforms.

.travis.env

@@ -1 +1 @@
-akvF272KZeVmQD6awMN6yn+lMRoCpRhhTDOrNahI0yshv57fqbpvOoHRKXv6WjbwKYIb0DaKrd0utbKIbtXDqdExJbUsfoGZojALrSrmWTJk2bVOCUVz1icFTUM/MIphglIupfmXQAy22R8jLkbVlQKcEQ1JjLZtLkluBjQUpBU=
+ENwfQv8SMFAoIazNkBk5xFatEg3MptXedUnPfUcMwMV3Ohez/3//maXhVC+Mrp0EXjolswOzbWeF0GhV/BEgVs3dtQcLVgd0HGkRnWrlutkz9NS9ViTC2cJ49TwA0bEUbX1Yod6tA3fwsHAi9k0WxmARNMGknObC6AAM9zXsINQ=

.travis.yml

@@ -9,7 +9,7 @@ matrix:
 env:
   global:
     - ARCHER_PUBLISH_VERSION=5.5
-    - secure: "akvF272KZeVmQD6awMN6yn+lMRoCpRhhTDOrNahI0yshv57fqbpvOoHRKXv6WjbwKYIb0DaKrd0utbKIbtXDqdExJbUsfoGZojALrSrmWTJk2bVOCUVz1icFTUM/MIphglIupfmXQAy22R8jLkbVlQKcEQ1JjLZtLkluBjQUpBU="
+    - secure: "ENwfQv8SMFAoIazNkBk5xFatEg3MptXedUnPfUcMwMV3Ohez/3//maXhVC+Mrp0EXjolswOzbWeF0GhV/BEgVs3dtQcLVgd0HGkRnWrlutkz9NS9ViTC2cJ49TwA0bEUbX1Yod6tA3fwsHAi9k0WxmARNMGknObC6AAM9zXsINQ="
 
 install:
   - ./.travis.install

composer.json

@@ -33,7 +33,7 @@
     ],
     "require": {
         "php": ">=5.3",
-        "eloquent/confetti": "~0.2.0",
+        "eloquent/confetti": "~0.3.0",
         "evenement/evenement": ">=1,<3",
         "icecave/isolator": "~2",
         "react/stream": ">=0.3,<0.5"

src/Base16/Base16DecodeTransform.php

@@ -12,20 +12,21 @@
 namespace Eloquent\Endec\Base16;
 
 use Eloquent\Confetti\AbstractTransform;
-use Eloquent\Confetti\TransformInterface;
+use Eloquent\Confetti\BufferedTransformInterface;
 use Eloquent\Endec\Exception\InvalidEncodedDataException;
 
 /**
  * Decodes data using base16 (hexadecimal) encoding.
  *
  * @link http://tools.ietf.org/html/rfc4648#section-8
  */
-class Base16DecodeTransform extends AbstractTransform
+class Base16DecodeTransform extends AbstractTransform implements
+    BufferedTransformInterface
 {
     /**
      * Get the static instance of this transform.
      *
-     * @return TransformInterface The transform.
+     * @return BufferedTransformInterface The transform.
      */
     public static function instance()
     {
@@ -76,5 +77,19 @@ public function transform($data, &$context, $isEnd = false)
         return array(pack('H*', $consumedData), $consume, null);
     }
 
+    /**
+     * Get the buffer size.
+     *
+     * This method is used to determine how much input is typically required
+     * before output can be produced. This can provide performance benefits by
+     * avoiding excessive method calls.
+     *
+     * @return integer The buffer size.
+     */
+    public function bufferSize()
+    {
+        return 2;
+    }
+
     private static $instance;
 }

src/Base16/Base16EncodeTransform.php

@@ -11,19 +11,19 @@
 
 namespace Eloquent\Endec\Base16;
 
-use Eloquent\Confetti\TransformInterface;
+use Eloquent\Confetti\BufferedTransformInterface;
 
 /**
  * Encodes data using base16 (hexadecimal) encoding.
  *
  * @link http://tools.ietf.org/html/rfc4648#section-8
  */
-class Base16EncodeTransform implements TransformInterface
+class Base16EncodeTransform implements BufferedTransformInterface
 {
     /**
      * Get the static instance of this transform.
      *
-     * @return TransformInterface The transform.
+     * @return BufferedTransformInterface The transform.
      */
     public static function instance()
     {
@@ -60,5 +60,19 @@ public function transform($data, &$context, $isEnd = false)
         return array(strtoupper(bin2hex($data)), strlen($data), null);
     }
 
+    /**
+     * Get the buffer size.
+     *
+     * This method is used to determine how much input is typically required
+     * before output can be produced. This can provide performance benefits by
+     * avoiding excessive method calls.
+     *
+     * @return integer The buffer size.
+     */
+    public function bufferSize()
+    {
+        return 1;
+    }
+
     private static $instance;
 }

src/Base32/AbstractBase32DecodeTransform.php

@@ -11,7 +11,7 @@
 
 namespace Eloquent\Endec\Base32;
 
-use Eloquent\Confetti\TransformInterface;
+use Eloquent\Confetti\BufferedTransformInterface;
 use Eloquent\Endec\Exception\EncodingExceptionInterface;
 use Eloquent\Endec\Exception\InvalidEncodedDataException;
 
@@ -20,7 +20,8 @@
  *
  * @link http://tools.ietf.org/html/rfc4648#section-6
  */
-abstract class AbstractBase32DecodeTransform implements TransformInterface
+abstract class AbstractBase32DecodeTransform implements
+    BufferedTransformInterface
 {
     /**
      * Transform the supplied data.
@@ -115,6 +116,20 @@ public function transform($data, &$context, $isEnd = false)
         return array($output, $consumed + $paddedLength - $length, null);
     }
 
+    /**
+     * Get the buffer size.
+     *
+     * This method is used to determine how much input is typically required
+     * before output can be produced. This can provide performance benefits by
+     * avoiding excessive method calls.
+     *
+     * @return integer The buffer size.
+     */
+    public function bufferSize()
+    {
+        return 8;
+    }
+
     private function map2($a, $b)
     {
         return chr($a << 3 | $b >> 2);

src/Base32/AbstractBase32EncodeTransform.php

@@ -11,14 +11,15 @@
 
 namespace Eloquent\Endec\Base32;
 
-use Eloquent\Confetti\TransformInterface;
+use Eloquent\Confetti\BufferedTransformInterface;
 
 /**
  * An abstract base class for implementing base32 encode transforms.
  *
  * @link http://tools.ietf.org/html/rfc4648#section-6
  */
-abstract class AbstractBase32EncodeTransform implements TransformInterface
+abstract class AbstractBase32EncodeTransform implements
+    BufferedTransformInterface
 {
     /**
      * Construct a new base32 encode transform.
@@ -100,6 +101,20 @@ public function transform($data, &$context, $isEnd = false)
         return array($output, $consumed, null);
     }
 
+    /**
+     * Get the buffer size.
+     *
+     * This method is used to determine how much input is typically required
+     * before output can be produced. This can provide performance benefits by
+     * avoiding excessive method calls.
+     *
+     * @return integer The buffer size.
+     */
+    public function bufferSize()
+    {
+        return 5;
+    }
+
     private function map1($a)
     {
         return $this->alphabet[($a >> 3)] .

src/Base32/Base32DecodeTransform.php

@@ -11,7 +11,7 @@
 
 namespace Eloquent\Endec\Base32;
 
-use Eloquent\Confetti\TransformInterface;
+use Eloquent\Confetti\BufferedTransformInterface;
 use Eloquent\Endec\Exception\EncodingExceptionInterface;
 use Eloquent\Endec\Exception\InvalidEncodedDataException;
 
@@ -25,7 +25,7 @@ class Base32DecodeTransform extends AbstractBase32DecodeTransform
     /**
      * Get the static instance of this transform.
      *
-     * @return TransformInterface The transform.
+     * @return BufferedTransformInterface The transform.
      */
     public static function instance()
     {

src/Base32/Base32EncodeTransform.php

@@ -11,7 +11,7 @@
 
 namespace Eloquent\Endec\Base32;
 
-use Eloquent\Confetti\TransformInterface;
+use Eloquent\Confetti\BufferedTransformInterface;
 
 /**
  * Encodes data using base32 encoding.
@@ -23,7 +23,7 @@ class Base32EncodeTransform extends AbstractBase32EncodeTransform
     /**
      * Get the static instance of this transform.
      *
-     * @return TransformInterface The transform.
+     * @return BufferedTransformInterface The transform.
      */
     public static function instance()
     {

src/Base32/Base32HexDecodeTransform.php

@@ -11,7 +11,7 @@
 
 namespace Eloquent\Endec\Base32;
 
-use Eloquent\Confetti\TransformInterface;
+use Eloquent\Confetti\BufferedTransformInterface;
 use Eloquent\Endec\Exception\EncodingExceptionInterface;
 use Eloquent\Endec\Exception\InvalidEncodedDataException;
 
@@ -25,7 +25,7 @@ class Base32HexDecodeTransform extends AbstractBase32DecodeTransform
     /**
      * Get the static instance of this transform.
      *
-     * @return TransformInterface The transform.
+     * @return BufferedTransformInterface The transform.
      */
     public static function instance()
     {

src/Base32/Base32HexEncodeTransform.php

@@ -11,7 +11,7 @@
 
 namespace Eloquent\Endec\Base32;
 
-use Eloquent\Confetti\TransformInterface;
+use Eloquent\Confetti\BufferedTransformInterface;
 
 /**
  * Encodes data using base32hex encoding.
@@ -23,7 +23,7 @@ class Base32HexEncodeTransform extends AbstractBase32EncodeTransform
     /**
      * Get the static instance of this transform.
      *
-     * @return TransformInterface The transform.
+     * @return BufferedTransformInterface The transform.
      */
     public static function instance()
     {

src/Base64/Base64DecodeTransform.php

@@ -12,20 +12,21 @@
 namespace Eloquent\Endec\Base64;
 
 use Eloquent\Confetti\AbstractTransform;
-use Eloquent\Confetti\TransformInterface;
+use Eloquent\Confetti\BufferedTransformInterface;
 use Eloquent\Endec\Exception\InvalidEncodedDataException;
 
 /**
  * Decodes data using base64 encoding.
  *
  * @link http://tools.ietf.org/html/rfc4648#section-4
  */
-class Base64DecodeTransform extends AbstractTransform
+class Base64DecodeTransform extends AbstractTransform implements
+    BufferedTransformInterface
 {
     /**
      * Get the static instance of this transform.
      *
-     * @return TransformInterface The transform.
+     * @return BufferedTransformInterface The transform.
      */
     public static function instance()
     {
@@ -85,5 +86,19 @@ public function transform($data, &$context, $isEnd = false)
         return array($outputBuffer, $consume, null);
     }
 
+    /**
+     * Get the buffer size.
+     *
+     * This method is used to determine how much input is typically required
+     * before output can be produced. This can provide performance benefits by
+     * avoiding excessive method calls.
+     *
+     * @return integer The buffer size.
+     */
+    public function bufferSize()
+    {
+        return 4;
+    }
+
     private static $instance;
 }

src/Base64/Base64EncodeTransform.php

@@ -12,19 +12,20 @@
 namespace Eloquent\Endec\Base64;
 
 use Eloquent\Confetti\AbstractTransform;
-use Eloquent\Confetti\TransformInterface;
+use Eloquent\Confetti\BufferedTransformInterface;
 
 /**
  * Encodes data using base64 encoding.
  *
  * @link http://tools.ietf.org/html/rfc4648#section-4
  */
-class Base64EncodeTransform extends AbstractTransform
+class Base64EncodeTransform extends AbstractTransform implements
+    BufferedTransformInterface
 {
     /**
      * Get the static instance of this transform.
      *
-     * @return TransformInterface The transform.
+     * @return BufferedTransformInterface The transform.
      */
     public static function instance()
     {
@@ -66,5 +67,19 @@ public function transform($data, &$context, $isEnd = false)
         return array(base64_encode(substr($data, 0, $consume)), $consume, null);
     }
 
+    /**
+     * Get the buffer size.
+     *
+     * This method is used to determine how much input is typically required
+     * before output can be produced. This can provide performance benefits by
+     * avoiding excessive method calls.
+     *
+     * @return integer The buffer size.
+     */
+    public function bufferSize()
+    {
+        return 3;
+    }
+
     private static $instance;
 }

src/Base64/Base64MimeDecodeTransform.php

@@ -11,7 +11,7 @@
 
 namespace Eloquent\Endec\Base64;
 
-use Eloquent\Confetti\TransformInterface;
+use Eloquent\Confetti\BufferedTransformInterface;
 use Eloquent\Endec\Exception\InvalidEncodedDataException;
 
 /**
@@ -24,7 +24,7 @@ class Base64MimeDecodeTransform extends Base64DecodeTransform
     /**
      * Get the static instance of this transform.
      *
-     * @return TransformInterface The transform.
+     * @return BufferedTransformInterface The transform.
      */
     public static function instance()
     {
@@ -98,10 +98,6 @@ public function transform($data, &$context, $isEnd = false)
                 $context
             );
 
-            if (null !== $error) {
-                return array('', 0, $error);
-            }
-
             $output .= $thisOutput;
 
             if ($consumed === strlen($buffer)) {