diff --git a/src/core/Akka.API.Tests/CoreAPISpec.ApproveStreams.approved.txt b/src/core/Akka.API.Tests/CoreAPISpec.ApproveStreams.approved.txt index 36c9e3c4436..a179c633103 100644 --- a/src/core/Akka.API.Tests/CoreAPISpec.ApproveStreams.approved.txt +++ b/src/core/Akka.API.Tests/CoreAPISpec.ApproveStreams.approved.txt @@ -1033,7 +1033,7 @@ namespace Akka.Streams.Dsl public Akka.Streams.IGraph, TMat> AddAttributes(Akka.Streams.Attributes attributes) { } public Akka.Streams.IGraph, TMat> Async() { } public Akka.Streams.Dsl.BidiFlow Atop(Akka.Streams.Dsl.BidiFlow bidi) { } - public Akka.Streams.Dsl.BidiFlow AtopMat(Akka.Streams.Dsl.BidiFlow bidi, System.Func combine) { } + public Akka.Streams.Dsl.BidiFlow AtopMat(Akka.Streams.Dsl.BidiFlow bidi, System.Func combine) { } public Akka.Streams.Dsl.Flow Join(Akka.Streams.Dsl.Flow flow) { } public Akka.Streams.Dsl.Flow JoinMat(Akka.Streams.Dsl.Flow flow, System.Func combine) { } public Akka.Streams.IGraph, TMat> Named(string name) { } diff --git a/src/core/Akka.Streams/Dsl/BidiFlow.cs b/src/core/Akka.Streams/Dsl/BidiFlow.cs index 46b52ed4ad6..6b4d094e0bb 100644 --- a/src/core/Akka.Streams/Dsl/BidiFlow.cs +++ b/src/core/Akka.Streams/Dsl/BidiFlow.cs @@ -278,13 +278,13 @@ public BidiFlow Atop(Bid /// TBD /// TBD /// TBD - public BidiFlow AtopMat(BidiFlow bidi, Func combine) + public BidiFlow AtopMat(BidiFlow bidi, Func combine) { var copy = bidi.Module.CarbonCopy(); var ins = copy.Shape.Inlets.ToArray(); var outs = copy.Shape.Outlets.ToArray(); - return new BidiFlow(Module + return new BidiFlow(Module .Compose(copy, combine) .Wire(Shape.Outlet1, ins[0]) .Wire(outs[1], Shape.Inlet2)