These are chat archives for akkadotnet/AkkaStreams
I havwe the following code:
var val = TestSource.SourceProbe<string>(this).Via(SnsPublisher.PublishToSNSFlow("topic-Arn", snsService)).ToMaterialized(Sink.Seq<PublishResponse>(), Keep.Both).Run(this.materializer);
var task =val.Item2.Wait(TimeSpan.FromSeconds(1)).Should().BeTrue();
the flow takes a string and an IAmazonSnsClient and returns a PublishResponse and is defined as:
public static Flow<string, PublishResponse, NotUsed> PublishToSNSFlow(string topicArn, IAmazonSimpleNotificationService snsService)
return Flow.FromGraph(new SNSPublishFlowStage(topicArn, snsService));
A couple of questions:
Firstly, how come I have to specify the type that Seq need? it can't seem to infer that on it's own.
Secondly the scala code is:
Await.result(future, 1.second) mustBe publishResult :: Nil
what is this testing, there is not publish result in the c# code.
help apreciated as always.