diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md
index fed22ac..1d725bb 100644
--- a/RELEASE_NOTES.md
+++ b/RELEASE_NOTES.md
@@ -1,2 +1,3 @@
-#### 0.1.0-beta002 - 2019-07-02
-* FEATURE: Initial Release
+#### 0.1.0-beta003 - 2019-07-12
+* FEATURE: Implements pollStreamForever
+* FEATURE: Implements readFromStream
diff --git a/src/FSharp.Control.Redis.Streams.Akka/AssemblyInfo.fs b/src/FSharp.Control.Redis.Streams.Akka/AssemblyInfo.fs
index b94f54c..a6c6b8f 100644
--- a/src/FSharp.Control.Redis.Streams.Akka/AssemblyInfo.fs
+++ b/src/FSharp.Control.Redis.Streams.Akka/AssemblyInfo.fs
@@ -5,19 +5,19 @@ open System.Reflection
 [<assembly: AssemblyTitleAttribute("FSharp.Control.Redis.Streams.Akka")>]
 [<assembly: AssemblyProductAttribute("FSharp.Control.Redis.Streams")>]
 [<assembly: AssemblyVersionAttribute("0.1.0")>]
-[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-02T00:00:00.0000000")>]
+[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-12T00:00:00.0000000")>]
 [<assembly: AssemblyFileVersionAttribute("0.1.0")>]
 [<assembly: AssemblyInformationalVersionAttribute("0.1.0")>]
 [<assembly: AssemblyMetadataAttribute("ReleaseChannel","beta")>]
-[<assembly: AssemblyMetadataAttribute("GitHash","a816153dbf4a4d9f8ade0688f62d3bc2b30082b6")>]
+[<assembly: AssemblyMetadataAttribute("GitHash","f0797eea8080ec9e87204e6ee70e205910b61b2a")>]
 do ()
 
 module internal AssemblyVersionInformation =
     let [<Literal>] AssemblyTitle = "FSharp.Control.Redis.Streams.Akka"
     let [<Literal>] AssemblyProduct = "FSharp.Control.Redis.Streams"
     let [<Literal>] AssemblyVersion = "0.1.0"
-    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-02T00:00:00.0000000"
+    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-12T00:00:00.0000000"
     let [<Literal>] AssemblyFileVersion = "0.1.0"
     let [<Literal>] AssemblyInformationalVersion = "0.1.0"
     let [<Literal>] AssemblyMetadata_ReleaseChannel = "beta"
-    let [<Literal>] AssemblyMetadata_GitHash = "a816153dbf4a4d9f8ade0688f62d3bc2b30082b6"
+    let [<Literal>] AssemblyMetadata_GitHash = "f0797eea8080ec9e87204e6ee70e205910b61b2a"
diff --git a/src/FSharp.Control.Redis.Streams.Hopac/AssemblyInfo.fs b/src/FSharp.Control.Redis.Streams.Hopac/AssemblyInfo.fs
index d3717d9..0be51b7 100644
--- a/src/FSharp.Control.Redis.Streams.Hopac/AssemblyInfo.fs
+++ b/src/FSharp.Control.Redis.Streams.Hopac/AssemblyInfo.fs
@@ -5,19 +5,19 @@ open System.Reflection
 [<assembly: AssemblyTitleAttribute("FSharp.Control.Redis.Streams.Hopac")>]
 [<assembly: AssemblyProductAttribute("FSharp.Control.Redis.Streams")>]
 [<assembly: AssemblyVersionAttribute("0.1.0")>]
-[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-02T00:00:00.0000000")>]
+[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-12T00:00:00.0000000")>]
 [<assembly: AssemblyFileVersionAttribute("0.1.0")>]
 [<assembly: AssemblyInformationalVersionAttribute("0.1.0")>]
 [<assembly: AssemblyMetadataAttribute("ReleaseChannel","beta")>]
-[<assembly: AssemblyMetadataAttribute("GitHash","a816153dbf4a4d9f8ade0688f62d3bc2b30082b6")>]
+[<assembly: AssemblyMetadataAttribute("GitHash","f0797eea8080ec9e87204e6ee70e205910b61b2a")>]
 do ()
 
 module internal AssemblyVersionInformation =
     let [<Literal>] AssemblyTitle = "FSharp.Control.Redis.Streams.Hopac"
     let [<Literal>] AssemblyProduct = "FSharp.Control.Redis.Streams"
     let [<Literal>] AssemblyVersion = "0.1.0"
-    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-02T00:00:00.0000000"
+    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-12T00:00:00.0000000"
     let [<Literal>] AssemblyFileVersion = "0.1.0"
     let [<Literal>] AssemblyInformationalVersion = "0.1.0"
     let [<Literal>] AssemblyMetadata_ReleaseChannel = "beta"
-    let [<Literal>] AssemblyMetadata_GitHash = "a816153dbf4a4d9f8ade0688f62d3bc2b30082b6"
+    let [<Literal>] AssemblyMetadata_GitHash = "f0797eea8080ec9e87204e6ee70e205910b61b2a"
diff --git a/src/FSharp.Control.Redis.Streams.Reactive/AssemblyInfo.fs b/src/FSharp.Control.Redis.Streams.Reactive/AssemblyInfo.fs
index fab86c3..bd5c441 100644
--- a/src/FSharp.Control.Redis.Streams.Reactive/AssemblyInfo.fs
+++ b/src/FSharp.Control.Redis.Streams.Reactive/AssemblyInfo.fs
@@ -5,19 +5,19 @@ open System.Reflection
 [<assembly: AssemblyTitleAttribute("FSharp.Control.Redis.Streams.Reactive")>]
 [<assembly: AssemblyProductAttribute("FSharp.Control.Redis.Streams")>]
 [<assembly: AssemblyVersionAttribute("0.1.0")>]
-[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-02T00:00:00.0000000")>]
+[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-12T00:00:00.0000000")>]
 [<assembly: AssemblyFileVersionAttribute("0.1.0")>]
 [<assembly: AssemblyInformationalVersionAttribute("0.1.0")>]
 [<assembly: AssemblyMetadataAttribute("ReleaseChannel","beta")>]
-[<assembly: AssemblyMetadataAttribute("GitHash","a816153dbf4a4d9f8ade0688f62d3bc2b30082b6")>]
+[<assembly: AssemblyMetadataAttribute("GitHash","f0797eea8080ec9e87204e6ee70e205910b61b2a")>]
 do ()
 
 module internal AssemblyVersionInformation =
     let [<Literal>] AssemblyTitle = "FSharp.Control.Redis.Streams.Reactive"
     let [<Literal>] AssemblyProduct = "FSharp.Control.Redis.Streams"
     let [<Literal>] AssemblyVersion = "0.1.0"
-    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-02T00:00:00.0000000"
+    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-12T00:00:00.0000000"
     let [<Literal>] AssemblyFileVersion = "0.1.0"
     let [<Literal>] AssemblyInformationalVersion = "0.1.0"
     let [<Literal>] AssemblyMetadata_ReleaseChannel = "beta"
-    let [<Literal>] AssemblyMetadata_GitHash = "a816153dbf4a4d9f8ade0688f62d3bc2b30082b6"
+    let [<Literal>] AssemblyMetadata_GitHash = "f0797eea8080ec9e87204e6ee70e205910b61b2a"
diff --git a/src/FSharp.Control.Redis.Streams/AssemblyInfo.fs b/src/FSharp.Control.Redis.Streams/AssemblyInfo.fs
index fa2016c..14729db 100644
--- a/src/FSharp.Control.Redis.Streams/AssemblyInfo.fs
+++ b/src/FSharp.Control.Redis.Streams/AssemblyInfo.fs
@@ -5,19 +5,19 @@ open System.Reflection
 [<assembly: AssemblyTitleAttribute("FSharp.Control.Redis.Streams")>]
 [<assembly: AssemblyProductAttribute("FSharp.Control.Redis.Streams")>]
 [<assembly: AssemblyVersionAttribute("0.1.0")>]
-[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-02T00:00:00.0000000")>]
+[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-12T00:00:00.0000000")>]
 [<assembly: AssemblyFileVersionAttribute("0.1.0")>]
 [<assembly: AssemblyInformationalVersionAttribute("0.1.0")>]
 [<assembly: AssemblyMetadataAttribute("ReleaseChannel","beta")>]
-[<assembly: AssemblyMetadataAttribute("GitHash","a816153dbf4a4d9f8ade0688f62d3bc2b30082b6")>]
+[<assembly: AssemblyMetadataAttribute("GitHash","f0797eea8080ec9e87204e6ee70e205910b61b2a")>]
 do ()
 
 module internal AssemblyVersionInformation =
     let [<Literal>] AssemblyTitle = "FSharp.Control.Redis.Streams"
     let [<Literal>] AssemblyProduct = "FSharp.Control.Redis.Streams"
     let [<Literal>] AssemblyVersion = "0.1.0"
-    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-02T00:00:00.0000000"
+    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-12T00:00:00.0000000"
     let [<Literal>] AssemblyFileVersion = "0.1.0"
     let [<Literal>] AssemblyInformationalVersion = "0.1.0"
     let [<Literal>] AssemblyMetadata_ReleaseChannel = "beta"
-    let [<Literal>] AssemblyMetadata_GitHash = "a816153dbf4a4d9f8ade0688f62d3bc2b30082b6"
+    let [<Literal>] AssemblyMetadata_GitHash = "f0797eea8080ec9e87204e6ee70e205910b61b2a"
diff --git a/tests/FSharp.Control.Redis.Streams.Akka.Tests/AssemblyInfo.fs b/tests/FSharp.Control.Redis.Streams.Akka.Tests/AssemblyInfo.fs
index b9f6ee6..0f670fd 100644
--- a/tests/FSharp.Control.Redis.Streams.Akka.Tests/AssemblyInfo.fs
+++ b/tests/FSharp.Control.Redis.Streams.Akka.Tests/AssemblyInfo.fs
@@ -5,19 +5,19 @@ open System.Reflection
 [<assembly: AssemblyTitleAttribute("FSharp.Control.Redis.Streams.Akka.Tests")>]
 [<assembly: AssemblyProductAttribute("FSharp.Control.Redis.Streams")>]
 [<assembly: AssemblyVersionAttribute("0.1.0")>]
-[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-02T00:00:00.0000000")>]
+[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-12T00:00:00.0000000")>]
 [<assembly: AssemblyFileVersionAttribute("0.1.0")>]
 [<assembly: AssemblyInformationalVersionAttribute("0.1.0")>]
 [<assembly: AssemblyMetadataAttribute("ReleaseChannel","beta")>]
-[<assembly: AssemblyMetadataAttribute("GitHash","a816153dbf4a4d9f8ade0688f62d3bc2b30082b6")>]
+[<assembly: AssemblyMetadataAttribute("GitHash","f0797eea8080ec9e87204e6ee70e205910b61b2a")>]
 do ()
 
 module internal AssemblyVersionInformation =
     let [<Literal>] AssemblyTitle = "FSharp.Control.Redis.Streams.Akka.Tests"
     let [<Literal>] AssemblyProduct = "FSharp.Control.Redis.Streams"
     let [<Literal>] AssemblyVersion = "0.1.0"
-    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-02T00:00:00.0000000"
+    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-12T00:00:00.0000000"
     let [<Literal>] AssemblyFileVersion = "0.1.0"
     let [<Literal>] AssemblyInformationalVersion = "0.1.0"
     let [<Literal>] AssemblyMetadata_ReleaseChannel = "beta"
-    let [<Literal>] AssemblyMetadata_GitHash = "a816153dbf4a4d9f8ade0688f62d3bc2b30082b6"
+    let [<Literal>] AssemblyMetadata_GitHash = "f0797eea8080ec9e87204e6ee70e205910b61b2a"
diff --git a/tests/FSharp.Control.Redis.Streams.Hopac.Tests/AssemblyInfo.fs b/tests/FSharp.Control.Redis.Streams.Hopac.Tests/AssemblyInfo.fs
index fe3c705..57d1959 100644
--- a/tests/FSharp.Control.Redis.Streams.Hopac.Tests/AssemblyInfo.fs
+++ b/tests/FSharp.Control.Redis.Streams.Hopac.Tests/AssemblyInfo.fs
@@ -5,19 +5,19 @@ open System.Reflection
 [<assembly: AssemblyTitleAttribute("FSharp.Control.Redis.Streams.Hopac.Tests")>]
 [<assembly: AssemblyProductAttribute("FSharp.Control.Redis.Streams")>]
 [<assembly: AssemblyVersionAttribute("0.1.0")>]
-[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-02T00:00:00.0000000")>]
+[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-12T00:00:00.0000000")>]
 [<assembly: AssemblyFileVersionAttribute("0.1.0")>]
 [<assembly: AssemblyInformationalVersionAttribute("0.1.0")>]
 [<assembly: AssemblyMetadataAttribute("ReleaseChannel","beta")>]
-[<assembly: AssemblyMetadataAttribute("GitHash","a816153dbf4a4d9f8ade0688f62d3bc2b30082b6")>]
+[<assembly: AssemblyMetadataAttribute("GitHash","f0797eea8080ec9e87204e6ee70e205910b61b2a")>]
 do ()
 
 module internal AssemblyVersionInformation =
     let [<Literal>] AssemblyTitle = "FSharp.Control.Redis.Streams.Hopac.Tests"
     let [<Literal>] AssemblyProduct = "FSharp.Control.Redis.Streams"
     let [<Literal>] AssemblyVersion = "0.1.0"
-    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-02T00:00:00.0000000"
+    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-12T00:00:00.0000000"
     let [<Literal>] AssemblyFileVersion = "0.1.0"
     let [<Literal>] AssemblyInformationalVersion = "0.1.0"
     let [<Literal>] AssemblyMetadata_ReleaseChannel = "beta"
-    let [<Literal>] AssemblyMetadata_GitHash = "a816153dbf4a4d9f8ade0688f62d3bc2b30082b6"
+    let [<Literal>] AssemblyMetadata_GitHash = "f0797eea8080ec9e87204e6ee70e205910b61b2a"
diff --git a/tests/FSharp.Control.Redis.Streams.Infrastructure.Tests/AssemblyInfo.fs b/tests/FSharp.Control.Redis.Streams.Infrastructure.Tests/AssemblyInfo.fs
new file mode 100644
index 0000000..6dc8b87
--- /dev/null
+++ b/tests/FSharp.Control.Redis.Streams.Infrastructure.Tests/AssemblyInfo.fs
@@ -0,0 +1,23 @@
+// Auto-Generated by FAKE; do not edit
+namespace System
+open System.Reflection
+
+[<assembly: AssemblyTitleAttribute("FSharp.Control.Redis.Streams.Infrastructure.Tests")>]
+[<assembly: AssemblyProductAttribute("FSharp.Control.Redis.Streams")>]
+[<assembly: AssemblyVersionAttribute("0.1.0")>]
+[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-12T00:00:00.0000000")>]
+[<assembly: AssemblyFileVersionAttribute("0.1.0")>]
+[<assembly: AssemblyInformationalVersionAttribute("0.1.0")>]
+[<assembly: AssemblyMetadataAttribute("ReleaseChannel","beta")>]
+[<assembly: AssemblyMetadataAttribute("GitHash","f0797eea8080ec9e87204e6ee70e205910b61b2a")>]
+do ()
+
+module internal AssemblyVersionInformation =
+    let [<Literal>] AssemblyTitle = "FSharp.Control.Redis.Streams.Infrastructure.Tests"
+    let [<Literal>] AssemblyProduct = "FSharp.Control.Redis.Streams"
+    let [<Literal>] AssemblyVersion = "0.1.0"
+    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-12T00:00:00.0000000"
+    let [<Literal>] AssemblyFileVersion = "0.1.0"
+    let [<Literal>] AssemblyInformationalVersion = "0.1.0"
+    let [<Literal>] AssemblyMetadata_ReleaseChannel = "beta"
+    let [<Literal>] AssemblyMetadata_GitHash = "f0797eea8080ec9e87204e6ee70e205910b61b2a"
diff --git a/tests/FSharp.Control.Redis.Streams.Reactive.Tests/AssemblyInfo.fs b/tests/FSharp.Control.Redis.Streams.Reactive.Tests/AssemblyInfo.fs
index 15d57c9..a590421 100644
--- a/tests/FSharp.Control.Redis.Streams.Reactive.Tests/AssemblyInfo.fs
+++ b/tests/FSharp.Control.Redis.Streams.Reactive.Tests/AssemblyInfo.fs
@@ -5,19 +5,19 @@ open System.Reflection
 [<assembly: AssemblyTitleAttribute("FSharp.Control.Redis.Streams.Reactive.Tests")>]
 [<assembly: AssemblyProductAttribute("FSharp.Control.Redis.Streams")>]
 [<assembly: AssemblyVersionAttribute("0.1.0")>]
-[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-02T00:00:00.0000000")>]
+[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-12T00:00:00.0000000")>]
 [<assembly: AssemblyFileVersionAttribute("0.1.0")>]
 [<assembly: AssemblyInformationalVersionAttribute("0.1.0")>]
 [<assembly: AssemblyMetadataAttribute("ReleaseChannel","beta")>]
-[<assembly: AssemblyMetadataAttribute("GitHash","a816153dbf4a4d9f8ade0688f62d3bc2b30082b6")>]
+[<assembly: AssemblyMetadataAttribute("GitHash","f0797eea8080ec9e87204e6ee70e205910b61b2a")>]
 do ()
 
 module internal AssemblyVersionInformation =
     let [<Literal>] AssemblyTitle = "FSharp.Control.Redis.Streams.Reactive.Tests"
     let [<Literal>] AssemblyProduct = "FSharp.Control.Redis.Streams"
     let [<Literal>] AssemblyVersion = "0.1.0"
-    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-02T00:00:00.0000000"
+    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-12T00:00:00.0000000"
     let [<Literal>] AssemblyFileVersion = "0.1.0"
     let [<Literal>] AssemblyInformationalVersion = "0.1.0"
     let [<Literal>] AssemblyMetadata_ReleaseChannel = "beta"
-    let [<Literal>] AssemblyMetadata_GitHash = "a816153dbf4a4d9f8ade0688f62d3bc2b30082b6"
+    let [<Literal>] AssemblyMetadata_GitHash = "f0797eea8080ec9e87204e6ee70e205910b61b2a"
diff --git a/tests/FSharp.Control.Redis.Streams.Tests/AssemblyInfo.fs b/tests/FSharp.Control.Redis.Streams.Tests/AssemblyInfo.fs
index fe3c705..9de7603 100644
--- a/tests/FSharp.Control.Redis.Streams.Tests/AssemblyInfo.fs
+++ b/tests/FSharp.Control.Redis.Streams.Tests/AssemblyInfo.fs
@@ -2,22 +2,22 @@
 namespace System
 open System.Reflection
 
-[<assembly: AssemblyTitleAttribute("FSharp.Control.Redis.Streams.Hopac.Tests")>]
+[<assembly: AssemblyTitleAttribute("FSharp.Control.Redis.Streams.Tests")>]
 [<assembly: AssemblyProductAttribute("FSharp.Control.Redis.Streams")>]
 [<assembly: AssemblyVersionAttribute("0.1.0")>]
-[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-02T00:00:00.0000000")>]
+[<assembly: AssemblyMetadataAttribute("ReleaseDate","2019-07-12T00:00:00.0000000")>]
 [<assembly: AssemblyFileVersionAttribute("0.1.0")>]
 [<assembly: AssemblyInformationalVersionAttribute("0.1.0")>]
 [<assembly: AssemblyMetadataAttribute("ReleaseChannel","beta")>]
-[<assembly: AssemblyMetadataAttribute("GitHash","a816153dbf4a4d9f8ade0688f62d3bc2b30082b6")>]
+[<assembly: AssemblyMetadataAttribute("GitHash","f0797eea8080ec9e87204e6ee70e205910b61b2a")>]
 do ()
 
 module internal AssemblyVersionInformation =
-    let [<Literal>] AssemblyTitle = "FSharp.Control.Redis.Streams.Hopac.Tests"
+    let [<Literal>] AssemblyTitle = "FSharp.Control.Redis.Streams.Tests"
     let [<Literal>] AssemblyProduct = "FSharp.Control.Redis.Streams"
     let [<Literal>] AssemblyVersion = "0.1.0"
-    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-02T00:00:00.0000000"
+    let [<Literal>] AssemblyMetadata_ReleaseDate = "2019-07-12T00:00:00.0000000"
     let [<Literal>] AssemblyFileVersion = "0.1.0"
     let [<Literal>] AssemblyInformationalVersion = "0.1.0"
     let [<Literal>] AssemblyMetadata_ReleaseChannel = "beta"
-    let [<Literal>] AssemblyMetadata_GitHash = "a816153dbf4a4d9f8ade0688f62d3bc2b30082b6"
+    let [<Literal>] AssemblyMetadata_GitHash = "f0797eea8080ec9e87204e6ee70e205910b61b2a"