dependabot-preview[bot] on nuget
Bump System.Configuration.Confi… (compare)
dependabot-preview[bot] on nuget
Bump NUnit from 3.7.1 to 3.13.1… (compare)
Aaronontheweb on dev
Bump FsCheck.Xunit from 2.15.1 … (compare)
Aaronontheweb on nuget
@Horusiath, I've been trying Akka.Streams, and I have couple of questions. For example I have this Scala code
override def eventsByTag(tag: String, offset: Long = 0L): Source[EventEnvelope, NotUsed] = {
Source.actorPublisher[EventEnvelope](EventsByTagPublisher.props(tag, offset, Long.MaxValue,
refreshInterval, maxBufSize, writeJournalPluginId)).mapMaterializedValue(_ ⇒ NotUsed)
.named("eventsByTag-" + URLEncoder.encode(tag, ByteString.UTF_8))
}
1) What should I use, instead of NotUsed? Unit/Unit.Instanse or something else?
2) I should return Source<EventEnvelope, Unit>, but method "Named" returns IGraph<SourceShape<EventEnvelope>, NotUsed>. How to convert SourceShape<T> to T?