Fix "Exception: Bad state: Future already completed.". Add onError stream for server ERROR frames.
Add onReceive stream to handle messages from server side subscribed queues.