pykka

pykka copied to clipboard

build(deps-dev): update flake8 requirement from ^4.0.1 to ^5.0.4

1

Updates the requirements on [flake8](https://github.com/pycqa/flake8) to permit the latest version. Commits 6027577 Release 5.0.4 213e006 Merge pull request #1653 from asottile/lower-bound-importlib-metadata e94ee2b require sufficiently new importlib-metadata 318a86a Merge pull request...

dependabot[bot]

Akka-style message Scheduler

5

First of all, thanks for Pykka, it's really nice! There is this issue about auto-scheduling: https://github.com/jodal/pykka/issues/53 I needed this functionality for my project as well, because I believe, that an...

akatashev

Implementation of priority queues/mailboxes

2

I had the need for a priority mailbox. I implemented priority queues pretty raw with touching the core part as less as possible. For the tell ask messages it looks...

julian-r

Delayed messages

9

This PR implements delayed message delivery, useful for creating event loops which can still be terminated at a moment's notice. Possibly fixes #44. Also fixes an unrelated bug in `eventlet.Event`...

fjarri

Akka style `Become` and `Unbecome`

1

Based on this issue: https://github.com/jodal/pykka/issues/38 This PR adds two methods to the standard `Actor` class: 1. Method `_become(self, func, *args, discard_old=True)` changes message handing behaviour to a specified function. *...

akatashev

with PlainActor.start(): your logical code.. then auto stop actor(__exit__)

linpan

Actors that drive their own event processing (or maybe have idle processing)

5

As I currently understand Pykka actors, they are entirely event driven in the sense that they don't do anything unless they've received an event. What I'm looking for is a...

abingham

Sender attribute?

5

Is there an equivalent of a `sender` attribute on the actor? This is to allow me to send messages to the "sender" --- and is drastically different from the "ask"...

drozzy

Support "become" to initialize actors with circular dependencies

2

Is it possible to provide support for "become" functionality in akka? See: http://doc.akka.io/docs/akka/snapshot/scala/actors.html#become-unbecome Seems like python should be particularly well-suited to such "hot-swapping". Thanks!

drozzy

Support multiprocessing

6

`multiprocessing` is like threading but a bit slower and allows multiple processors fully.

acertain