Is there a way to obtain the socket being subscribed by WebSocketSubject?
When a certain condition happens I need to close the underlying socket.
I tried to close it by complete() but it didn't close the socket. The unsubscribed doesn't work either.
Could anybody help me? Or point me in the right direction?
For having correct socket disconnect you should unsubscribe websocketsubject itself, not it's subscription: https://github.com/ReactiveX/rxjs/blob/master/src/internal/observable/dom/WebSocketSubject.ts#L295
More accurate way is to call complete() on WebSocketSubject. But there is one more solution. You can obtain socket using code like this. It`s bad, but works too.
var wrapper: any = subject;
wrapper._socket.close();
You can call unsubscribe() directly on the WebSocketSubject instance that unsubscribes all observers:
const subject = Observable.webSocket(...);
...
subject.unsubscribe();
See source code: https://github.com/ReactiveX/rxjs/blob/master/src/observable/dom/WebSocketSubject.ts#L269