Concurrency operators exhibit registration race condition

```
Operators working with multiple sources have problem with initial registration.
Depending on the operator.

The first problem is that the registration and remembering is usually not
protected by a lock, or the half constucted defaultobserver escapes. I.e., when
the registration happens, the source might send values immediately.

The second problem is that if a registration triggers execution which brings
the observer into a completed state, any subsequent registrations are
unnecessary, but still happen and will bombard the defaultobserver indefinitely.

Solution:

- protect the sub-registrations with the same observer lock.
- after each registration, check if the observer completed and do not register
further

Therefore the defaultobserver has 5 "messages"

onNext, onError, onFinish, onClose, onRegister

```

Original issue reported on code.google.com by `akarn...@gmail.com` on 4 Apr 2012 at 5:54

Commencez par localiser les opérateurs de concurrence et les chemins d’enregistrement de DefaultObserver décrits dans l’issue, puis examinez comment les sous-enregistrements et la finalisation de l’observer sont synchronisés. Reproduisez un cas où un enregistrement émet ou se termine immédiatement. Le travail est terminé lorsque les enregistrements sont protégés par le verrou de l’observer et qu’aucune autre source n’est enregistrée après la finalisation, avec une couverture des cinq messages de l’observer.

Rédigé par le modèle d'indexation à partir du texte de l'issue.