subscribe

open suspend override fun subscribe(callback: (Message) -> Unit): () -> Unit

Starts the subscription and invokes the callback whenever an event occurs.

Return

A function to call to unsubscribe/cleanup

Parameters

callback

Function to call with messages when events occur