reef-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Andrew Chung (JIRA)" <>
Subject [jira] [Commented] (REEF-1453) GroupCommunication should create a new observer for each client
Date Fri, 17 Jun 2016 18:25:05 GMT


Andrew Chung commented on REEF-1453:

I also don't think that we should base all our logic on Java, since C# {{IObservable}} s allow
us to be much more natural and flexible with our message passing and {{Exception}} handling.
{{EventHandler}} in Java does not have the equivalent of {{OnComplete}} and {{OnException}},
which is why it needs to put a special message into the queue.

> GroupCommunication should create a new observer for each client
> ---------------------------------------------------------------
>                 Key: REEF-1453
>                 URL:
>             Project: REEF
>          Issue Type: Improvement
>          Components: REEF.NET
>            Reporter: Andrew Chung
>            Assignee: Andrew Chung
>              Labels: FT
> {{GroupCommunication}} currently only has one universal observer that handles connections
for all incoming clients. This is inconvenient because when a client fails or disconnects,
there is no easy way to propagate the failure/completion signal of the *specific* failed client
up to the universal observer.
> Provided that each {{CommunicationGroupClient}} knows all its downstream nodes and can
reverse-lookup the endpoints, the {{CommunicationGroupClient}} should only create an observer
for each endpoint instead of using the universal observer.

This message was sent by Atlassian JIRA

View raw message