You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
// create a sourcevarsender=Sender;StreamLogs(request.StreamId)// materialize it using stream refs.RunWith(StreamRefs.SourceRef<string>(),Context.System.Materializer())// and send to sender.PipeTo(sender,success: sourceRef =>newLogsOffer(request.StreamId,sourceRef));
But is INSTEAD refactored to
// create a sourcevarsender=Sender;StreamLogs(request.StreamId)// materialize it using stream refs.RunWith(StreamRefs.SourceRef<string>(),Context.System.Materializer())// and send to sender.PipeTo(sender));
The success: sourceRef => new LogsOffer(request.StreamId, sourceRef) gets deleted by accident here.
Expected behavior
Only the replyTo argument on the PipeTo call should be changed, not 100% of the arguments.
Actual behavior
The success: sourceRef => new LogsOffer(request.StreamId, sourceRef) gets deleted by accident here.
Additional context
If there are any other optional parameters for PipeTo, we should add cases to cover those inside the code fix test suite for it as well. Do this exhaustively so we ensure that there are no problems.
The text was updated successfully, but these errors were encountered:
Version Information
Version of Akka.NET? v0.1.1
Which Akka.NET Modules? Akka.Analyzer
Describe the bug
We have the following original code:
https://github.com/akkadotnet/akka.net/blob/2633f914122b42aae87de807cee1561ab9749f27/src/core/Akka.Docs.Tests/Streams/StreamRefsDocTests.cs#L56-L61
It should be refactored to:
But is INSTEAD refactored to
The
success: sourceRef => new LogsOffer(request.StreamId, sourceRef)
gets deleted by accident here.Expected behavior
Only the
replyTo
argument on thePipeTo
call should be changed, not 100% of the arguments.Actual behavior
The
success: sourceRef => new LogsOffer(request.StreamId, sourceRef)
gets deleted by accident here.Additional context
If there are any other optional parameters for
PipeTo
, we should add cases to cover those inside the code fix test suite for it as well. Do this exhaustively so we ensure that there are no problems.The text was updated successfully, but these errors were encountered: