WebSocketSubject may have different input and output types.

Just what the title says... The AnonymousSubject (aka "frankensubject") probably also needs some typings love.

Basically, a nicer interface would be:

class WebSocketSubject<In, Out> extends Observable<Out> implements Observer<In> {
  // ...stuff
}