Merge branch 'master' into ingester

jet · Jun 7, 2019 · 064d787 · 064d787
2 parents 397ae45 + d25b806
commit 064d787
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/equinox-projector/Consumer/Consumer.fsproj b/equinox-projector/Consumer/Consumer.fsproj
@@ -16,7 +16,7 @@
     <PackageReference Include="Argu" Version="5.4.0" />
     <PackageReference Include="Destructurama.FSharp.NetCore" Version="1.0.14" />
     <PackageReference Include="Equinox.Codec" Version="2.0.0-preview9" />
-    <PackageReference Include="Propulsion.Kafka" Version="1.0.1-rc1" />
+    <PackageReference Include="Propulsion.Kafka" Version="1.0.1-rc2" />
     <PackageReference Include="Serilog.Sinks.Console" Version="3.1.1" />
   </ItemGroup>
 

diff --git a/equinox-projector/Projector/Program.fs b/equinox-projector/Projector/Program.fs
@@ -156,7 +156,7 @@ let hackDropBigBodies (e : Propulsion.Streams.StreamEvent<_>) : Propulsion.Strea
 
 let mapToStreamItems (docs : Microsoft.Azure.Documents.Document seq) : Propulsion.Streams.StreamEvent<_> seq =
     docs
-    |> Seq.collect DocumentParser.enumEvents
+    |> Seq.collect EquinoxCosmosParser.enumStreamEvents
     // TODO use Seq.filter and/or Seq.map to adjust what's being sent
     |> Seq.map hackDropBigBodies
 

diff --git a/equinox-projector/Projector/Projector.fsproj b/equinox-projector/Projector/Projector.fsproj
@@ -13,9 +13,9 @@
   <ItemGroup>
     <PackageReference Include="Argu" Version="5.4.0" />
     <PackageReference Include="Destructurama.FSharp.NetCore" Version="1.0.14" />
-    <PackageReference Include="Propulsion.Cosmos" Version="1.0.1-rc1" />
+    <PackageReference Include="Propulsion.Cosmos" Version="1.0.1-rc2" />
     <!--#if (kafka)-->
-    <PackageReference Include="Propulsion.Kafka" Version="1.0.1-rc1" />
+    <PackageReference Include="Propulsion.Kafka" Version="1.0.1-rc2" />
     <!--#endif-->
     <PackageReference Include="Serilog.Sinks.Console" Version="3.1.1" />
   </ItemGroup>