1 files changed, 99 insertions, 0 deletions
diff --git a/intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Socket/StreamFunctions.php b/intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Socket/StreamFunctions.php
new file mode 100644
index 0000000..6f793f8
--- /dev/null
+++ b/intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Socket/StreamFunctions.php
@@ -0,0 +1,99 @@
+<?php
+
+namespace Pheanstalk\Socket;
+
+/**
+ * Wrapper around PHP stream functions.
+ * Facilitates mocking/stubbing stream operations in unit tests.
+ *
+ * @author Paul Annesley
+ * @package Pheanstalk
+ * @license http://www.opensource.org/licenses/mit-license.php
+ */
+class StreamFunctions
+{
+    private static $_instance;
+
+    /**
+     * Singleton accessor.
+     */
+    public static function instance()
+    {
+        if (empty(self::$_instance)) {
+            self::$_instance = new self;
+        }
+
+        return self::$_instance;
+    }
+
+    /**
+     * Sets an alternative or mocked instance.
+     */
+    public function setInstance($instance)
+    {
+        self::$_instance = $instance;
+    }
+
+    /**
+     * Unsets the instance, so a new one will be created.
+     */
+    public function unsetInstance()
+    {
+        self::$_instance = null;
+    }
+
+    // ----------------------------------------
+
+    public function feof($handle)
+    {
+        return feof($handle);
+    }
+
+    public function fgets($handle, $length = null)
+    {
+        if (isset($length)) {
+            return fgets($handle, $length);
+        } else {
+            return fgets($handle);
+        }
+    }
+
+    public function fopen($filename, $mode)
+    {
+        return fopen($filename, $mode);
+    }
+
+    public function fread($handle, $length)
+    {
+        return fread($handle, $length);
+    }
+
+    public function fsockopen($hostname, $port = -1, &$errno = null, &$errstr = null, $timeout = null)
+    {
+        return @fsockopen($hostname, $port, $errno, $errstr, $timeout);
+    }
+
+    public function pfsockopen($hostname, $port = -1, &$errno = null, &$errstr = null, $timeout = null)
+    {
+        return @pfsockopen($hostname, $port, $errno, $errstr, $timeout);
+    }
+
+    public function fwrite($handle, $string, $length = null)
+    {
+        if (isset($length)) {
+            return fwrite($handle, $string, $length);
+        } else {
+            return fwrite($handle, $string);
+        }
+    }
+
+    public function fclose($handle)
+    {
+        fclose($handle);
+    }
+
+    public function stream_set_timeout($stream, $seconds, $microseconds = 0)
+    {
+        return stream_set_timeout($stream, $seconds, $microseconds);
+    }
+}