initial commit

Author: Richard Whaling

README.md

@@ -1,2 +1,78 @@
 # native-loop
-Extensible event loop and async-oriented IO for Scala Native; powered by libuv
+Extensible event loop and async-oriented IO for Scala Native; powered by libuv.
+
+Shameless plug: code mostly adapted from my book, [Modern Systems Programming in Scala Native](https://pragprog.com/book/rwscala/modern-systems-programming-with-scala-native)
+
+## What is it?
+native-loop provides a real, asynchronous ExecutionContext/Future implementation for Scala Native.
+It's backed by libuv, the same C library that the node.js ecosystem runs on; in addition to basic 
+Future dispatching, we can also use libuv to provide other basic functionality, like:
+
+- File IO
+- Pipe IO
+- TCP Sockets
+- UDP Sockets
+- Timers
+
+To provide a working API for practical, async Scala Native programs, we have two subprojects,
+`client` and `server`, which provide an async HTTP client and server, respectively, by integrating addtional C libraries: [nodejs/http-parser](https://github.com/nodejs/http-parser) for request parsing, and [curl](https://github.com/curl/curl) for a full featured client with HTTPS support.
+
+That said - providing a full-featured ecosystem in a single library isn't feasible - instead, we provide a `LoopExtension` trait that allows other C libaries to be integrated to the underlying event loop, in the same way that libcurl and http-parser are integrated; this opens up the possiblity of fully asynchronous bindings for postgres, redis, and many others.
+
+## Why is this here?
+
+To demonstrate the architectural style of a full, extensible async ecosystem for Scala Native, with an idiomatic Future-based API, implemented entirely as a library, and to start discussion about what we our priorities are.  
+
+## Maintenance Status
+
+This code is a pre-release preview - I am cleaning up both the style and the implementation, 
+aiming to align with Scala Native 0.4 for something more robust.  
+
+For now, I'm filing issues to remind myself of work that needs to be done.
+
+I'll also create a few "discussion" issues for broader conversation.
+
+Please feel free to file additional issues with questions, comments, and concerns!
+
+## Server API Example
+
+```
+  def main(args:Array[String]):Unit = {
+    Service()
+      .getAsync("/async") { r => Future { 
+          s"got (async routed) request $r"
+        }.map { message => OK(
+            Map("asyncMessage" -> message)      
+          )
+        }
+      }      
+      .getAsync("/fetch/example") { r => 
+        Curl.get(c"https://www.example.com").map { response =>
+          Response(200,"OK",Map(),response.body)
+        }
+      }
+      .get("/") { r => OK {
+          Map("default_message" -> s"got (default routed) request $r")
+        }
+      }
+      .run(9999)
+    uv_run(EventLoop.loop, UV_RUN_DEFAULT)
+  }
+```
+
+## Streaming API Example
+
+```
+  def main(args:Array[String]):Unit = {
+    val p = FilePipe(c"./data.txt")
+    .map { d => 
+      println(s"consumed $d") 
+      d
+    }.addDestination(Tokenizer("\n"))
+    .addDestination(Tokenizer(" "))
+    .map { d => d + "\n" }
+    .addDestination(FileOutputPipe(c"./output.txt", false))
+    println("running")
+    uv_run(EventLoop.loop,UV_RUN_DEFAULT)
+  }
+```

build.sbt

@@ -0,0 +1,35 @@
+lazy val commonSettings = Seq(
+  organization := "dev.whaling",
+  version := "preview",
+  scalaVersion := "2.11.12",
+  libraryDependencies += "io.argonaut" % "argonaut_native0.3_2.11" % "6.2.3"
+)
+
+lazy val core = (project in file("core"))
+                .settings(commonSettings:_*)
+                .enablePlugins(ScalaNativePlugin)
+
+lazy val pipe = (project in file("pipe"))
+                     .settings(commonSettings:_*)
+                     .enablePlugins(ScalaNativePlugin)
+                     .dependsOn(core)
+
+lazy val client = (project in file("client"))
+                 .settings(commonSettings:_*)
+                 .enablePlugins(ScalaNativePlugin)
+                 .dependsOn(core)
+
+lazy val server = (project in file("server"))
+             	 	 .settings(commonSettings:_*)
+                 .enablePlugins(ScalaNativePlugin)
+                 .dependsOn(core)
+
+lazy val serverExample = (project in file("server-example"))
+             	 	 .settings(commonSettings:_*)
+                 .enablePlugins(ScalaNativePlugin)
+                 .dependsOn(core,server,client)
+
+lazy val pipeExample = (project in file("pipe-example"))
+             	 	 .settings(commonSettings:_*)
+                 .enablePlugins(ScalaNativePlugin)
+                 .dependsOn(core,pipe,client)