Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • Nov 19 21:12
    dependabot-preview[bot] synchronize #128
  • Nov 19 21:12

    dependabot-preview[bot] on nuget

    Bump Microsoft.NET.Test.Sdk fro… (compare)

  • Nov 19 21:12
    dependabot-preview[bot] edited #128
  • Nov 19 21:12
    Danthar commented #128
  • Nov 19 21:11
    dependabot-preview[bot] edited #128
  • Nov 19 21:11
    Danthar commented #128
  • Nov 19 21:11

    dependabot-preview[bot] on nuget

    (compare)

  • Nov 19 21:10

    Danthar on dev

    Bump AkkaVersion from 1.3.15 to… Merge pull request #129 from ak… (compare)

  • Nov 19 21:10
    Danthar closed #129
  • Nov 19 21:08
    Danthar commented #4045
  • Nov 19 21:08
    Danthar labeled #4045
  • Nov 19 21:08
    Danthar labeled #4045
  • Nov 19 20:44
    dependabot-preview[bot] synchronize #129
  • Nov 19 20:44

    dependabot-preview[bot] on nuget

    Bump AkkaVersion from 1.3.15 to… (compare)

  • Nov 19 20:43
    dependabot-preview[bot] edited #129
  • Nov 19 20:43
    dependabot-preview[bot] synchronize #128
  • Nov 19 20:43

    dependabot-preview[bot] on nuget

    Bump Microsoft.NET.Test.Sdk fro… (compare)

  • Nov 19 20:43
    dependabot-preview[bot] edited #128
  • Nov 19 20:43
    dependabot-preview[bot] edited #129
  • Nov 19 20:42
    Danthar commented #129
Tomasz Jaskula
@tjaskula
Is this the only way defining parent/child relationship with FSharp API ? cc: @Horusiath
let playback = 
        spawn system "Playback"
        <| fun parentMailbox ->
            let child = 
                spawn parentMailbox "child" 
                    <| fun childMailbox ->
                        childMailbox.Defer (fun () -> printfn "Child stopping")
                        printfn "Child started"
                        let rec childLoop() = actor {
                            let! msg = childMailbox.Receive()
                            return! childLoop()
                        }
                        childLoop()
            cprintfn ConsoleColor.Gray "Creating parent actor..."
            // define parent behavior
            let rec loop() = actor {
                let! msg = parentMailbox.Receive()
                child.Forward(msg)  // forward all messages through
                return! loop ()
            }
            loop ()
Bartosz Sypytkowski
@Horusiath
@tjaskula using Akka.FSharp? Yes. But in normal conditions you'd probably move child behavior to separate function
Arsene T. Gandote
@Tochemey
@ronnyek you can build a full blown reactive Web applications using Akka without clustering and Akka remote. It is sth I have done.
Weston
@ronnyek
Basically shooting for say a web application and another worker service
Seems like good have remote or something for that
You'd need
Arsene T. Gandote
@Tochemey
OK
Weston
@ronnyek
You'd know more than I would... I am just saying from my minimal experience... That seems like that would be the case
Arsene T. Gandote
@Tochemey
Never mind
Carey Free
@Cawifre
@llehn In the case of Autofac, you pass the container and the actor system into the constructor for AutoFacDependencyResolver and the wiring is automagic under the hood. You can see an example on the Akka.DI.AutoFac readme. (Incidentally, what is with the inconsistent capitalization all over that repo? Should always be "Autofac", not "AutoFac".) If this world is even a little kind, then the plug-ins for other containers work the same way.
Weston
@ronnyek
any hope of .net core support, or are is it more likely that support will come with netstandard2? I know there were a few diff issues in github, but seems like all were kinda outstanding
adityasharmacs
@adityasharmacs

Hi All, I am trying out Journaling using Mongo Db, just wanted to know if apart frmo the github repo "https://github.com/akkadotnet/Akka.Persistence.MongoDB" is there any place where I can get code that explains Database storage in Journaling for MongoDb ? I have also read the following pages:

  1. https://petabridge.com/blog/intro-to-persistent-actors/
  2. http://bartoszsypytkowski.com/how-akka-net-persistence-works/

But didn't come across a pseudo code that shows entries being saved into Database using Journaling in MongoDb.

Any help is highly appreciated.

Bartosz Sypytkowski
@Horusiath
@adityasharmacs I guess, that the test suite for this plugin would be a first place to go. Also AFAIK MongoDB plugin requires setting bson schema attributes for each type - which instances will you persist - manually at actor system startup
adityasharmacs
@adityasharmacs
Hi @Horusiath : I am newbie to this, can you please give me some more pointers on this? Or any more references where I should look it up?
Bartosz Sypytkowski
@Horusiath
@adityasharmacs I'm not sure, where you could possibly find more references. Maybe @Silv3rcircl3 could help
fanoI
@fanoI
Good Afternoon! I've two questions regarding Akka.Net / Actors:
  1. It is possible to start an application as command line and then create an Actor than span a GUI (Winform, WPF or GTK#), there is an example of communication with Winform but another Actor is created in the UI thread, I'd like to make the GUI an Actor itself
  2. What about databases? Can I make an Actor that deals with the DB using Entity Framework?
Marc Piechura
@marcpiechura
@adityasharmacs you need to register your event types and snapshot types in the BsonClassMap before you can use them. Regarding examples, any available for persistence should work, you only need to change the hocon config and add the types to the class map
Michael Chandler
@optiks
@Aaronontheweb, commit 69709352
....changes the CreateTestProbe() behaviour to create the test actor under system, instead of user. Is this a deliberate change?
This breaks some of tests which rely on ActorSelection.
TestKitBase.cs:449 FYI
Daniel Söderberg
@raskolnikoov
@Danthar @Horusiath @Aaronontheweb what's the difference between Akka.Testkit.Xunit/Xunit2 ?
Marc Piechura
@marcpiechura
@raskolnikoov the Xunit version it targets ;-)
Lev Lehn
@llehn
@Cawifre thx
Daniel Söderberg
@raskolnikoov
can somebody who knows provide an example with Akka.Testkit where the childactors uses Context.DI.Props<T>() ? I get errors on this and dont know how to test my actors where it uses DI
System.NullReferenceException
Alex Valuyskiy
@alexvaluyskiy
@raskolnikoov there is no difference anymore. Both depend on Xunit2
Aaron Stannard
@Aaronontheweb
@raskolnikoov although not anymore - as of 1.2 both of them are the same essentially
we dropped support for XUnit1
Arsene T. Gandote
@Tochemey
Hello. I can see the akka stream is now stable. However there is no great documentation or tutorial around. Every time I have to go and read the JVM version and Tuto the JVM guys have put online. Please can you guys who has used well share some real world scenario tutorial that can help we novice in it.
Michael Chandler
@optiks
@Aaronontheweb any idea if the CreateTestProbe() behaviour change was deliberate? (see more detail above)
fanoI
@fanoI

Is it possible to launch the UI Event Loop from an Actor? Only if that Actor will exist the GUI should run this works with a Command Line application but not in Akka.Net Actor:

       [STAThread] //optional
        protected static bool StartUILoop()
        {
            Application.Run();
            return true;
        }

        protected override void PreStart()
        {
            /* Let's start an Empty UI Application, the true Application will load the page with "Loading..." */
            //Task mytask = Task.Run(() => Application.Run());

            Task mytask = Task.Run(() =>
                StartUILoop()
            );
        }

then when I receive the load command I simply do:

                    var form = new LoginForm();
                    form.Show();

the form is effectively shown but is not working is not active, label text is not drawn and if I move the mouse in it I get the spin wheel!

Thank you for your help...

I've tried to create the Actor in the UI thread using dispatcher = akka.actor.synchronized-dispatcher but nothing changes I suspect it is because I've created a Task not the normal UI thread
Marc Piechura
@marcpiechura
@Tochemey we have ported the complete documentation from the jvm too. Can you give me a link with the tutorials your referring to?
Arsene T. Gandote
@Tochemey

@Silv3rcircl3 I have gone through few of them.
https://www.slideshare.net/Lightbend/understanding-akka-streams-back-pressure-and-asynchronous-architectures?next_slideshow=1

https://www.slideshare.net/rolandkuhn/akka-streams-and-http

https://github.com/pkinsky/akka-streams-example

https://www.slideshare.net/joy87/a-dive-into-akka-streams-from-the-basics-to-a-realworld-scenario

The documentation is great. I am disputing that. However you gusy have used in production if you guys can write some tutos like the one Bartosz wrote on Akka.IO it will help us as starting point.

Marc Piechura
@marcpiechura
The example from pkinsky is probably worth porting it. I think the only one that is using Akka.Streams in production is @Aaronontheweb ;-) And we have the webcrawler example that is now using Akka.Streams, see petabridge/akkadotnet-code-samples@fcc6025
Aaron Stannard
@Aaronontheweb
@optiks the change was deliberate
ensures that the test probes and test actors only get shut down after the user-defined actors
did that end up breaking some of your specs?
(it also was meant to bring us in line with the JVM)
Michael Chandler
@optiks
@Aaronontheweb Okie, thanks. Yep, it broke some of tests which were testing code which was using ActorSelection
mhsjlw
@mhsjlw
Hey! I'd like to implement a game server in Akka.NET using F#, can anyone point me to docs for using TCP I/O in F#? I can't find any other than the C# ones
Weston
@ronnyek
I'd really like to utilize akka.net, I wish the timing was better. Sadly it seem slike there are options that support netcore or will in the very very near future =(
seems like there is a possibility of that in AKKA.net world
but that soem of these issues have just een oustanding for a while
Bartosz Sypytkowski
@Horusiath
@mhsjlw here is the basic TCP listener in Akkling: https://github.com/Horusiath/Akkling/blob/master/examples/io.fsx
but it's using pure actors, not streams. I'll try to provide some examples of stream-based TCP once I'll have finish #2405 (which is actually already complete, but I want to focus on better memory usage and potential micro optimizations)
Arsene T. Gandote
@Tochemey
Hello does Akka Stream has scodec?
as one the in-built Stage
Arsene T. Gandote
@Tochemey
Hello how can I use the Akka Streams with F#?