How to use the @pulumi/azure.eventhub function in @pulumi/azure

// Copyright 2016-2019, Pulumi Corporation.  All rights reserved.

import * as azure from "@pulumi/azure";
import * as pulumi from "@pulumi/pulumi";
import { createSharedAccessToken } from "./token";

// Create an Azure Resource Group
const resourceGroup = new azure.core.ResourceGroup("streams-rg");

// Define an Event Hub Namespace with two Hubs for an input and an output data streams
const namespace = new azure.eventhub.EventHubNamespace("streams-ns", {
    resourceGroupName: resourceGroup.name,
    sku: "standard",
});

const inputHub = new azure.eventhub.EventHub("inputs", {
    resourceGroupName: resourceGroup.name,
    namespaceName: namespace.name,
    partitionCount: 2,
    messageRetention: 7,
});

const consumerGroup = new azure.eventhub.EventHubConsumerGroup("analytics", {
    resourceGroupName: resourceGroup.name,
    namespaceName: namespace.name,
    eventhubName: inputHub.name,
});

// Copyright 2016-2019, Pulumi Corporation.  All rights reserved.

import * as azure from "@pulumi/azure";
import * as pulumi from "@pulumi/pulumi";
import { createSharedAccessToken } from "./token";

// Create an Azure Resource Group
const resourceGroup = new azure.core.ResourceGroup("streams-rg");

// Define an Event Hub Namespace with two Hubs for an input and an output data streams
const namespace = new azure.eventhub.EventHubNamespace("streams-ns", {
    resourceGroupName: resourceGroup.name,
    sku: "standard",
});

const inputHub = new azure.eventhub.EventHub("inputs", {
    resourceGroupName: resourceGroup.name,
    namespaceName: namespace.name,
    partitionCount: 2,
    messageRetention: 7,
});

const consumerGroup = new azure.eventhub.EventHubConsumerGroup("analytics", {
    resourceGroupName: resourceGroup.name,
    namespaceName: namespace.name,
    eventhubName: inputHub.name,
});

const outputHub = new azure.eventhub.EventHub("outputs", {
    resourceGroupName: resourceGroup.name,
    namespaceName: namespace.name,
    partitionCount: 2,

constructor(name: string, opts?: pulumi.ResourceOptions) {
        super("cloud:topic:Topic", name, {}, opts);

        const namespace = new azure.eventhub.Namespace(name, {
            location: shared.location,
            resourceGroupName: shared.globalResourceGroupName,
            // topics are only supported in standard and premium.
            sku: "standard",
        }, { parent: this });

        const topic = new azure.eventhub.Topic(name, {
            resourceGroupName: shared.globalResourceGroupName,
            namespaceName: namespace.name,
        }, { parent: this });

        this.namespace = namespace;
        this.topic = topic;

        this.subscribe = (name, handler) => {
            const subscription = serverless.eventhub.onTopicEvent(
                name, namespace, topic, {
                    ...shared.defaultSubscriptionArgs,
                    func: (context, val) => {
                        handler(val).then(() => context.done());
                    },
                }, { parent: this });

constructor(name: string, opts?: pulumi.ResourceOptions) {
        super("cloud:topic:Topic", name, {}, opts);

        const namespace = new azure.eventhub.Namespace(name, {
            location: shared.location,
            resourceGroupName: shared.globalResourceGroupName,
            // topics are only supported in standard and premium.
            sku: "standard",
        }, { parent: this });

        const topic = new azure.eventhub.Topic(name, {
            resourceGroupName: shared.globalResourceGroupName,
            namespaceName: namespace.name,
        }, { parent: this });

        this.namespace = namespace;
        this.topic = topic;

        this.subscribe = (name, handler) => {
            const subscription = serverless.eventhub.onTopicEvent(