trying to rip the std.stream out

source/dyaml/dumper.d

@@ -12,9 +12,10 @@
 module dyaml.dumper;
 
 
-import std.stream;
+//import std.stream;
 import std.typecons;
 
+import dyaml.stream;
 import dyaml.anchor;
 import dyaml.emitter;
 import dyaml.encoding;
@@ -59,7 +60,7 @@ import dyaml.tagdirective;
  * Write to memory:
  * --------------------
  * import std.stream;
- * auto stream = new MemoryStream();
+ * auto stream = new YMemoryStream();
  * auto node = Node([1, 2, 3, 4, 5]);
  * Dumper(stream).dump(node);
  * --------------------
@@ -83,20 +84,20 @@ struct Dumper
     unittest
     {
         auto node = Node([1, 2, 3, 4, 5]);
-        Dumper(new MemoryStream()).dump(node);
+        Dumper(new YMemoryStream()).dump(node);
     }
    
     unittest
     {
         auto node1 = Node([1, 2, 3, 4, 5]);
         auto node2 = Node("This document contains only one string");
-        Dumper(new MemoryStream()).dump(node1, node2);
+        Dumper(new YMemoryStream()).dump(node1, node2);
     }
        
     unittest
     {
-        import std.stream;
+        //import std.stream;
-        auto stream = new MemoryStream();
+        auto stream = new YMemoryStream();
         auto node = Node([1, 2, 3, 4, 5]);
         Dumper(stream).dump(node);
     }
@@ -106,7 +107,7 @@ struct Dumper
         auto node = Node([1, 2, 3, 4, 5]);
         auto representer = new Representer();
         auto resolver = new Resolver();
-        auto dumper = Dumper(new MemoryStream());
+        auto dumper = Dumper(new YMemoryStream());
         dumper.representer = representer;
         dumper.resolver = resolver;
         dumper.dump(node);
@@ -119,7 +120,7 @@ struct Dumper
         Representer representer_;
 
         //Stream to write to.
-        Stream stream_;
+        YStream stream_;
         //True if this Dumper owns stream_ and needs to destroy it in the destructor.
         bool weOwnStream_ = false;
 
@@ -160,8 +161,10 @@ struct Dumper
         this(string filename) @trusted
         {
             name_ = filename;
-            try{this(new File(filename, FileMode.OutNew));}
+            //try{this(new File(filename, FileMode.OutNew));}
-            catch(StreamException e)
+            try{this(new YFile(filename));}
+            //catch(StreamException e)
+            catch(Exception e)
             {
                 throw new YAMLException("Unable to open file " ~ filename ~ 
                                         " for YAML dumping: " ~ e.msg);
@@ -171,7 +174,7 @@ struct Dumper
         }
 
         ///Construct a Dumper writing to a _stream. This is useful to e.g. write to memory.
-        this(Stream stream) @safe
+        this(YStream stream) @safe
         {
             resolver_    = new Resolver();
             representer_ = new Representer();

source/dyaml/emitter.d

@@ -18,12 +18,13 @@ import std.conv;
 import std.exception;
 import std.format;
 import std.range;
-import std.stream;
+//import std.stream;
 import std.string;
 import std.system;
 import std.typecons;
 import std.utf;
 
+import dyaml.stream;
 import dyaml.anchor;
 import dyaml.encoding;
 import dyaml.escapes;
@@ -81,7 +82,7 @@ struct Emitter
             [TagDirective("!", "!"), TagDirective("!!", "tag:yaml.org,2002:")];
 
         ///Stream to write to.
-        Stream stream_;
+        YStream stream_;
         ///Encoding can be overriden by STREAM-START.
         Encoding encoding_ = Encoding.UTF_8;
 
@@ -163,12 +164,12 @@ struct Emitter
         /**
          * Construct an emitter.
          *
-         * Params:  stream    = Stream to write to. Must be writable.
+         * Params:  stream    = YStream to write to. Must be writable.
          *          canonical = Write scalars in canonical form?
          *          indent    = Indentation width.
          *          lineBreak = Line break character/s.
          */
-        this(Stream stream, const bool canonical, const int indent, const int width, 
+        this(YStream stream, const bool canonical, const int indent, const int width, 
              const LineBreak lineBreak) @trusted
         in{assert(stream.writeable, "Can't emit YAML to a non-writable stream");}
         body
@@ -331,7 +332,7 @@ struct Emitter
         void expectStreamStart() @trusted
         {
             enforce(eventTypeIs(EventID.StreamStart),
-                    new Error("Expected StreamStart, but got " ~ event_.idString));
+                    new Error("Expected YStreamStart, but got " ~ event_.idString));
 
             encoding_ = event_.encoding;
             writeStreamStart();
@@ -350,7 +351,7 @@ struct Emitter
         void expectDocumentStart(Flag!"first" first)() @trusted
         {
             enforce(eventTypeIs(EventID.DocumentStart) || eventTypeIs(EventID.StreamEnd),
-                    new Error("Expected DocumentStart or StreamEnd, but got " 
+                    new Error("Expected DocumentStart or YStreamEnd, but got " 
                               ~ event_.idString));
 
             if(event_.id == EventID.DocumentStart)

source/dyaml/loader.d

@@ -24,7 +24,7 @@ import dyaml.scanner;
 import dyaml.token;
 
 
-/** Loads YAML documents from files or streams.
+/** Loads YAML documents from files or char[].
  *
  * User specified Constructor and/or Resolver can be used to support new
  * tags / data types.
@@ -140,12 +140,6 @@ struct Loader
             }
         }
 
-        deprecated("Loader.fromString(string) is deprecated. Use Loader.fromString(char[]) instead.")
-        static Loader fromString(string data)
-        {
-            return Loader(cast(ubyte[])data.dup);
-        }
-
         /** Construct a Loader to load YAML from a string (char []).
          *
          * Params:  data = String to load YAML from. $(B will) be overwritten during
@@ -168,25 +162,6 @@ struct Loader
             assert(Loader.fromString(cast(char[])"42").load().as!int == 42);
         }
 
-        import std.stream;
-        deprecated("Loader(Stream) is deprecated. Use Loader(ubyte[]) instead.")
-        this(Stream stream) @safe
-        {
-            try
-            {
-                import dyaml.streamcompat;
-                auto streamBytes  = streamToBytesGC(stream);
-                reader_           = new Reader(streamBytes);
-                scanner_          = new Scanner(reader_);
-                parser_           = new Parser(scanner_);
-            }
-            catch(YAMLException e)
-            {
-                throw new YAMLException("Unable to open stream %s for YAML loading: %s"
-                                        .format(name_, e.msg));
-            }
-        }
-
         /** Construct a Loader to load YAML from a buffer.
          *
          * Params: yamlData = Buffer with YAML data to load. This may be e.g. a file

source/dyaml/representer.d

@@ -676,7 +676,7 @@ Node representMyClass(ref Node node, Representer representer) @system
     return representer.representScalar("!myclass.tag", scalar);
 }
 
-import std.stream;
+import dyaml.stream;
 
 unittest
 {
@@ -684,7 +684,7 @@ unittest
                 &representMyStructSeq, 
                 &representMyStructMap])
     {
-        auto dumper = Dumper(new MemoryStream());
+        auto dumper = Dumper(new YMemoryStream());
         auto representer = new Representer;
         representer.addRepresenter!MyStruct(r);
         dumper.representer = representer;
@@ -694,7 +694,7 @@ unittest
 
 unittest
 {
-    auto dumper = Dumper(new MemoryStream());
+    auto dumper = Dumper(new YMemoryStream());
     auto representer = new Representer;
     representer.addRepresenter!MyClass(&representMyClass);
     dumper.representer = representer;

source/dyaml/stream.d

@@ -0,0 +1,36 @@
+module dyaml.stream;
+
+interface YStream {
+	void writeExact(const void* buffer, size_t size);
+	size_t write(const(ubyte)[] buffer);
+}
+
+class YMemoryStream : YStream {
+	ubyte[] data;
+
+	void writeExact(const void* buffer, size_t size) {
+		data ~= cast(ubyte[])buffer[0 .. size];
+	}
+
+	size_t write(const(ubyte)[] buffer) {
+		data ~= buffer;
+		return buffer.length;
+	}
+}
+
+class YFile : YStream {
+	static import std.stdio;
+	std.stdio.File file;
+
+	this(string fn) {
+		this.file = std.stdio.File(fn, "w");
+	}
+
+	void writeExact(const void* buffer, size_t size) {
+		this.file.write(buffer[0 .. size]);
+	}
+
+	size_t write(const(ubyte)[] buffer) {
+		this.file.write(buffer[0 .. size]);
+	}
+}

source/dyaml/testemitter.d

@@ -83,7 +83,7 @@ void testEmitterOnData(bool verbose, string dataFilename, string canonicalFilena
     //Must exist due to Anchor, Tags reference counts.
     auto loader = Loader(dataFilename);
     auto events = cast(Event[])loader.parse();
-    auto emitStream = new MemoryStream;
+    auto emitStream = new YMemoryStream;
     Dumper(emitStream).emit(events);
 
     if(verbose)
@@ -114,7 +114,7 @@ void testEmitterOnCanonical(bool verbose, string canonicalFilename)
     auto events = cast(Event[])loader.parse();
     foreach(canonical; [false, true])
     {
-        auto emitStream = new MemoryStream;
+        auto emitStream = new YMemoryStream;
         auto dumper = Dumper(emitStream);
         dumper.canonical = canonical;
         dumper.emit(events);
@@ -174,7 +174,7 @@ void testEmitterStyles(bool verbose, string dataFilename, string canonicalFilena
                     }
                     styledEvents ~= event;
                 }
-                auto emitStream = new MemoryStream;
+                auto emitStream = new YMemoryStream;
                 Dumper(emitStream).emit(styledEvents);
                 if(verbose)
                 {