From bfcd1b520fd79b893e721ba916ae5e1656407d2f Mon Sep 17 00:00:00 2001
From: Luke Pulverenti <luke.pulverenti@gmail.com>
Date: Wed, 16 Aug 2017 02:43:41 -0400
Subject: merge common implementations and server implementations

---
 .../IO/SharpCifs/Util/Sharpen/OutputStream.cs      | 86 ++++++++++++++++++++++
 1 file changed, 86 insertions(+)
 create mode 100644 Emby.Server.Implementations/IO/SharpCifs/Util/Sharpen/OutputStream.cs

(limited to 'Emby.Server.Implementations/IO/SharpCifs/Util/Sharpen/OutputStream.cs')

diff --git a/Emby.Server.Implementations/IO/SharpCifs/Util/Sharpen/OutputStream.cs b/Emby.Server.Implementations/IO/SharpCifs/Util/Sharpen/OutputStream.cs
new file mode 100644
index 0000000000..0e6189f0cb
--- /dev/null
+++ b/Emby.Server.Implementations/IO/SharpCifs/Util/Sharpen/OutputStream.cs
@@ -0,0 +1,86 @@
+using System;
+using System.IO;
+
+namespace SharpCifs.Util.Sharpen
+{
+    public class OutputStream : IDisposable
+	{
+		protected Stream Wrapped;
+
+		public static implicit operator OutputStream (Stream s)
+		{
+			return Wrap (s);
+		}
+
+		public static implicit operator Stream (OutputStream s)
+		{
+			return s.GetWrappedStream ();
+		}
+		
+		public virtual void Close ()
+		{
+			if (Wrapped != null) {
+                //Stream.`Close` method deleted
+                //Wrapped.Close ();
+                Wrapped.Dispose();
+            }
+		}
+
+		public void Dispose ()
+		{
+			Close ();           
+		}
+
+		public virtual void Flush ()
+		{
+			if (Wrapped != null) {
+				Wrapped.Flush ();
+			}
+		}
+
+		internal Stream GetWrappedStream ()
+		{
+			// Always create a wrapper stream (not directly Wrapped) since the subclass
+			// may be overriding methods that need to be called when used through the Stream class
+			return new WrappedSystemStream (this);
+		}
+
+		static internal OutputStream Wrap (Stream s)
+		{
+			OutputStream stream = new OutputStream ();
+			stream.Wrapped = s;
+			return stream;
+		}
+
+		public virtual void Write (int b)
+		{
+			if (Wrapped is WrappedSystemStream)
+				((WrappedSystemStream)Wrapped).OutputStream.Write (b);
+			else {
+				if (Wrapped == null)
+					throw new NotImplementedException ();
+				Wrapped.WriteByte ((byte)b);
+			}
+		}
+
+		public virtual void Write (byte[] b)
+		{
+			Write (b, 0, b.Length);
+		}
+
+		public virtual void Write (byte[] b, int offset, int len)
+		{
+			if (Wrapped is WrappedSystemStream)
+				((WrappedSystemStream)Wrapped).OutputStream.Write (b, offset, len);
+			else {
+				if (Wrapped != null) {
+					Wrapped.Write (b, offset, len);
+				} else {
+					for (int i = 0; i < len; i++) {
+						Write (b[i + offset]);
+					}
+				}
+			}
+		}
+	}
+}
-- 
cgit v1.2.3