Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 14:26
    nagytech commented #3954
  • 11:18
    nagytech edited #4089
  • 11:17
    nagytech opened #4089
  • 11:00
    nagytech commented #4083
  • 08:34
    jiyeongj commented #4083
  • 08:33
    jiyeongj commented #4083
  • 08:33
    jiyeongj commented #4083
  • 07:57

    dependabot-preview[bot] on nuget

    (compare)

  • 07:57

    dependabot-preview[bot] on dev

    Bump MongoDB.Driver from 2.9.1 … (compare)

  • 07:57
    dependabot-preview[bot] closed #104
  • 07:52
    dependabot-preview[bot] synchronize #104
  • 07:52

    dependabot-preview[bot] on nuget

    Bump MongoDB.Driver from 2.9.1 … (compare)

  • 07:52
    dependabot-preview[bot] edited #104
  • 07:51
    dependabot-preview[bot] edited #104
  • 07:51
    dependabot-preview[bot] edited #104
  • 07:51
    Aaronontheweb commented #104
  • 07:43

    dependabot-preview[bot] on nuget

    (compare)

  • 07:43

    dependabot-preview[bot] on dev

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

  • 07:43
    dependabot-preview[bot] closed #102
  • 07:43
    Aaronontheweb commented #102
Marc Piechura
@marcpiechura
@Sam13 that’s the line for opening the file, don’t know out of my head if you could write it differently to support unlocked reads https://github.com/akkadotnet/akka.net/blob/3f924fda8d6ca55c5af90a710d23be8ce36d5c7a/src/core/Akka.Streams/Implementation/IO/FilePublisher.cs#L110
But if so we would probably accept a PR ;-)
Sam13
@Sam13
@alexhofer @Danthar @marcpiechura I have an actor which distributes files, if two client actors want the same file it's opened twice.
I think it's a bug in Akka since System.IO.FileInfo.Open which is used uses FileShare.None as default argument (FileStream.Openuses FileShare.Read as default).
I'll try to create a PR
Sam13
@Sam13
Done: akkadotnet/akka.net#3531
I really had trouble to get the unit tests running - most of them are failing - any help would be appreciated...
AndreSteenbergen
@AndreSteenbergen
Hey guys, I currently have an Flow wich starts with a Source created by Source.ActorRef<T>. And I have an actor pushing things in there. This publisher is way too fast. This method does not allow for Backpressuring. How would I create a source with Backpressure, is there an example I can follow?
AndreSteenbergen
@AndreSteenbergen
Something like this?
source = Source.ActorPublisher<ProcessPostcode>
source.Buffer(10, OverflowStrategy.Backpressure);
Marc Piechura
@marcpiechura
@AndreSteenbergen you could use Source.Queue and pass the queue to the actor but you need to stash/buffer messages inside the actor if the queue can't handle more messages
so you have to implement backpressure in the actor itself, there is no build in way to automatically backpressure an actor source
AndreSteenbergen
@AndreSteenbergen
I figured that out already, that's why I am trying to implement the ActorPublisher<T>, that would work to right?
Marc Piechura
@marcpiechura
but why ? :) do you really need an IActorRef for whatever pushes messages into the stream?
AndreSteenbergen
@AndreSteenbergen
Good question, no I don't
Marc Piechura
@marcpiechura
Then I would take the queue and use this as your input gateway
Stijn Herreman
@stijnherreman
Is it possible to use async/await in a FSM actor? Like how ReceiveActor has ReceiveAsync.
Stijn Herreman
@stijnherreman
Hmm, I guess I will have to make another attempt at fully grasping PipeTo :smile:
fleed
@fleed
using TestKit, can I synchronously wait the handling of a message (Tell(message))?
Stijn Herreman
@stijnherreman
@fleed There's a third-party library that may help you, see divverence/MarbleTesting#4. I didn't end up using it and went with always sending an ACK message instead to signal completion of a task.
fleed
@fleed
Thank you @stijnherreman
EricFowler
@EricFowler
Super easy n00bie question: Why is 'Sys' undefined in my c# akka.net application?
Alex Hofer
@alexhofer
@EricFowler mind posting the line in question?
EricFowler
@EricFowler
I can do that. It is just the starter sample from the tutorial at https://getakka.net/articles/intro/tutorial-1.html

using Akka;
using Akka.Actor;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace MyAkka
{
class Program
{
public class PrintMyActorRefActor : UntypedActor
{
protected override void OnReceive(object message)
{
switch (message)
{
case "printit":
IActorRef secondRef = Context.ActorOf(Props.Empty, "second-actor");
Console.WriteLine($"Second: {secondRef}");
break;
}
}
}
static void Main(string[] args)
{
Console.WriteLine("Hello World!");
var firstRef = Sys.ActorOf(Props.Create<PrintMyActorRefActor>(), "first-actor");
Console.WriteLine($"First: {firstRef}");
firstRef.Tell("printit", ActorRefs.NoSender);
Console.ReadKey();
}
}
}

The problem is here:
var firstRef = Sys.ActorOf(Props.Create<PrintMyActorRefActor>(), "first-actor");
EricFowler
@EricFowler
@alexhofer Just posted a reply; want to make sure you know about it :-)
Vasily Kirichenko
@vasily-kirichenko
@EricFowler enclose code snippets with triple back ticks (```) to format them as code
v1rusw0rm
@v1rusw0rm
@EricFowler Sys is not Akka class, it looks like a property of object which contains tutorial code snippets.
var sys = ActorSystem.Create("tutorial-actor-system");
var firstRef = sys.ActorOf(Props.Create<PrintMyActorRefActor>(), "first-actor");
fleed
@fleed
@Aaronontheweb is it planned to implement a clean way in TestKit to wait that an actor completes the handling of a message? Currently, after a actor.Tell(something), I need to put a Thread.Sleep() or a await Task.Delay(), which doesn’t look a proper way of testing.. unless I’m missing an existing way to accomplish it. I wouldn’t like to add reply messages just to be able to test the code
Chris Dewar-English
@babelchips
Hi - hoping for a bit of clarification on something. Should I be able to run both a .NET Framework 4.5.2 node and a .NET Core 2.1 node on the same cluster and have them communicate ok? A .NET Standard shared library for the message objects should work, right?
Vasily Kirichenko
@vasily-kirichenko
@babelchips no, this is not suported
Chris Dewar-English
@babelchips
@vasily-kirichenko Ah ok.
@vasily-kirichenko Is it a serialisation issue?
Arjen Smits
@Danthar
@babelchips yes. A netstandard 2.0 compatible version is in the works.
to11mtm
@to11mtm
Hey guys... Is there some sort of rule about Priority Mailboxes and Tell/Ask from outside the system? I've got a thing happening where it looks like none of my messages sent from outside the system (directly, i.e. local IActorRef) are going through the mailbox.
the message gets received by the actor, and when the actor gets messages from it's children (The only other thing really inside the system) those do go through the mailbox
to11mtm
@to11mtm
Ahhh.... I think I figured it out. It looks like mailbox gets involved in prioritizing when there is more than one message enqueued to the mailbox!
Arsene
@Tochemey
Hello can some one point to me the package which contains the HttpRequest component in Akka Streams
Aaron Stannard
@Aaronontheweb
@babelchips akkadotnet/akka.net#2947
the out of the box JSON.NET serialization won't work
due to the namespaces for primitive types in .NET being different
from how they are in .NET Core
so a .NET 4.5.2 string can't be successfully deserialized back into a .NET Core 2.1 string without that
no idea why Microsoft did that
but there it is
if you implement a custom serializer like Google Protobuf
or MsgPack
or just use that hack with JSON.NET
you'll be good to go
Chris Dewar-English
@babelchips
@Aaronontheweb Interesting. I think I’ll give that a go. Thanks.
Marc Piechura
@marcpiechura
@Tochemey I don’t think we have a HttpRequest component in akka.streams