-record(subscription, {
    'receive' :: fun(() -> {ok, any()} | {error, nil}),
    cancel :: fun(() -> nil)
}).