DMleadgen
46d973904b
Next.js website for Rocky Mountain Vending company featuring: - Product catalog with Stripe integration - Service areas and parts pages - Admin dashboard with Clerk authentication - SEO optimized pages with JSON-LD structured data Co-authored-by: Cursor <cursoragent@cursor.com>
60 lines
2.6 KiB
Text
60 lines
2.6 KiB
Text
import { NormalizedSchema } from "@smithy/core/schema";
|
|
import { EventStreamMarshaller, HttpRequest as IHttpRequest, HttpResponse as IHttpResponse, SerdeFunctions, ShapeDeserializer, ShapeSerializer } from "@smithy/types";
|
|
/**
|
|
* Separated module for async mixin of EventStream serde capability.
|
|
* This is used by the HttpProtocol base class from \@smithy/core/protocols.
|
|
*
|
|
* @public
|
|
*/
|
|
export declare class EventStreamSerde {
|
|
private readonly marshaller;
|
|
private readonly serializer;
|
|
private readonly deserializer;
|
|
private readonly serdeContext?;
|
|
private readonly defaultContentType;
|
|
/**
|
|
* Properties are injected by the HttpProtocol.
|
|
*/
|
|
constructor({ marshaller, serializer, deserializer, serdeContext, defaultContentType, }: {
|
|
marshaller: EventStreamMarshaller;
|
|
serializer: ShapeSerializer<string | Uint8Array>;
|
|
deserializer: ShapeDeserializer<string | Uint8Array>;
|
|
serdeContext?: SerdeFunctions;
|
|
defaultContentType: string;
|
|
});
|
|
/**
|
|
* @param eventStream - the iterable provided by the caller.
|
|
* @param requestSchema - the schema of the event stream container (struct).
|
|
* @param [initialRequest] - only provided if the initial-request is part of the event stream (RPC).
|
|
*
|
|
* @returns a stream suitable for the HTTP body of a request.
|
|
*/
|
|
serializeEventStream({ eventStream, requestSchema, initialRequest, }: {
|
|
eventStream: AsyncIterable<any>;
|
|
requestSchema: NormalizedSchema;
|
|
initialRequest?: any;
|
|
}): Promise<IHttpRequest["body"] | Uint8Array>;
|
|
/**
|
|
* @param response - http response from which to read the event stream.
|
|
* @param unionSchema - schema of the event stream container (struct).
|
|
* @param [initialResponseContainer] - provided and written to only if the initial response is part of the event stream (RPC).
|
|
*
|
|
* @returns the asyncIterable of the event stream for the end-user.
|
|
*/
|
|
deserializeEventStream({ response, responseSchema, initialResponseContainer, }: {
|
|
response: IHttpResponse;
|
|
responseSchema: NormalizedSchema;
|
|
initialResponseContainer?: any;
|
|
}): Promise<AsyncIterable<{
|
|
[key: string]: any;
|
|
$unknown?: unknown;
|
|
}>>;
|
|
/**
|
|
* @param unionMember - member name within the structure that contains an event stream union.
|
|
* @param unionSchema - schema of the union.
|
|
* @param event
|
|
*
|
|
* @returns the event body (bytes) and event type (string).
|
|
*/
|
|
private writeEventBody;
|
|
}
|