So far I understood that *persistDoc* is another function that should
persist something into the appropriate file. However I believe that in my
case it is a flow, that has some source and sink attached, and the sink is
the *FileIO*.
Basically, I don't see how that is supposed to work out - *Fil
Hi there everyone,
Just a quick-fix the current documentation.
"com.typesafe.akka" %% "akka-http-testkit" % "2.4.12"
:s/2.4.12/2.4.11/g
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>
Hi there,
Actually the text mentioned;
"com.typesafe.akka" %% "akka-http-experimental" % "3.0.0-RC1"
has not been updated and throws an error when updating / compiling if used.
"com.typesafe.akka" %% "akka-http-experimental" % "3.0.0-RC1"
:s/akka-http-experimental/akka-http/g
On Wednesd
Hi There,
Not sure what the process is to get documentation changes pushed to
production - if it isn't automatic...
Nonetheless, the change is not reflected, yet, on the online documentation.
On Wednesday, 19 October 2016 04:45:08 UTC+11, Konrad Malawski wrote:
>
> Thanks for noticing, that's
Sorry,
This change is required at;
http://akka.io/docs/
On Sunday, 6 November 2016 01:39:13 UTC+11, Gavin Baumanis wrote:
>
> Hi there everyone,
>
> Just a quick-fix the current documentation.
>
> "com.typesafe.akka" %% "akka-http-testkit" % "2.4.12"
> :s/2.4.12/2.4.11/g
>
>
>
--
>>
Hi there everyone,
Just a quick-fix for the information displayed at;
http://akka.io/docs/
"com.typesafe.akka" %% "akka-http-testkit" % "2.4.12"
:s/2.4.12/2.4.11/g
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/curr
Hi,
Thanks for reporting!
I think that the issue is that `akka-http-testkit` wasn't moved to the
separate list with the rest of `akka-http` dependencies that are on their
own versioning scheme now (2.4.11 at the moment, 3.0/10.0 soon-ish).
I've opened a pull request [1] to fix that.
But I suppos
If I understood, it's enough replace map(persistDoc) by via(persistDoc), if
persitDoc is a flow. The fold stage is to aggregate the number of
persistence operations performed by persistDoc stage. I understood you want
to fetch a list of docs related to a profile, persist them and so update
the
Okay, perhaps the simple source snippet will make it clear:
type OptProfile = Option[FullProfile]
type LikesAndCount = (Int, Stream[Profile])
val src: Source[Int, NotUsed] = Source[Int](Conf.startId() to Conf.endId
())
val fetchProfileFlow: Flow[Int, OptProfile, NotUsed] = Flow.fr
