Calls subscriber with {:on_event, event}, expecting :ok as result in order to apply backpressure.

Executes fun function for decoding response and responds on that message.

Sends subscription request and waits for positive response. Returns {:ok, subscription_confirmation}.

Sends unsubscribe request and remembers who it should respond to when response is received. Response will arrive to subscription as push message.