Orleankka 0.10.9 (for early feedback)
Pre-release
Pre-release
New features
Added ability to choose stream subscription target (actor id) for every item dynamically. Syntax:
[StreamSubscription(Source = "sms:foo", Target = "ComputeTarget()")]
class SomeConsumerActor : Actor
{
static string ComputeTarget(object item) => "bar";
}
Note: ()
parenthesis need to be used, to specify that the value of Target should be treated as a function, rather than just a static value.
Api changes & fixes
Syntax for specifying predicate functions in StreamSubscription
Filter property was changed for consistency with Target string function specification syntax. Add ()
to the end of string to denote that value is a function.
[StreamSubscription(Source = "sms:foo", Filter = "SelectItem()")]