import { Subscription } from 'rxjs';
import type { DocumentType, GraphQLAuthMode } from '@aws-amplify/core/internals/utils';
export interface SubscriptionObserver<T> {
    next(value: T): void;
    error(errorValue: any): void;
}
export interface EventsChannel {
    /**
     * @experimental API may change in future versions
     *
     * Subscribe to Events
     *
     * @example
     * const channel = await events.connect("default/channel")
     *
     * channel.subscribe({
     *   next: (data) => { console.log(data) },
     *   error: (err) => { console.error(err) },
     * })
     *
     * @example // authMode override
     * channel.subscribe({
     *   next: (data) => { console.log(data) },
     *   error: (err) => { console.error(err) },
     * }, { authMode: 'userPool' })
     *
     * @param observer - observer callback handlers
     * `{ next: () => {}, error: () => {}}`
     *
     * @param options - subscribe overrides: `authMode`, `authToken`
     *
     */
    subscribe(observer: SubscriptionObserver<any>, subOptions?: EventsOptions): Subscription;
    /**
     * @experimental API may change in future versions
     *
     * Publish events to a channel via WebSocket
     *
     * @example
     * const channel = await events.connect("default/channel")
     *
     * await channel.publish({ some: "data" });
     *
     * @example // event batching
     * await channel.publish("default/channel", [{ some: "event" }, { some: "event2" }])
     *
     * @example // authMode override
     * await channel.publish({ some: "data" }, { authMode: "userPool" });
     *
     * @param event - JSON-serializable value or an array of values
     * @param pubOptions - request overrides: `authMode`, `authToken`
     *
     * @returns void on success
     * @throws on error
     */
    publish(event: DocumentType, pubOptions?: EventsOptions): Promise<any>;
    /**
     * @experimental API may change in future versions
     *
     * Close channel and any active subscriptions
     *
     * @example
     * const channel = await events.connect("default/channel")
     *
     * channel.close()
     *
     */
    close(): void;
}
export type ResolvedGraphQLAuthModes = Exclude<GraphQLAuthMode, 'identityPool'>;
export interface EventsOptions {
    authMode?: GraphQLAuthMode;
    authToken?: string;
    apiKey?: string;
}
export interface PublishedEvent {
    identifier: string;
    index: number;
}
export interface PublishResponse {
    failed: PublishedEvent[];
    successful: PublishedEvent[];
}
interface EventsConfigure {
    appSyncGraphqlEndpoint: string;
    region?: string;
    authenticationType: ResolvedGraphQLAuthModes;
    apiKey?: string;
}
export type ProviderOptions = EventsConfigure & {
    authToken?: string;
};
export {};