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 "fire and forget" request to EventStoreDB.