import type { AnyMessage, Message, MethodInfo, PartialMessage, ServiceType } from '@bufbuild/protobuf'; import { type ContextValues, type StreamResponse, type Transport, type UnaryResponse } from '@connectrpc/connect'; import SessionManager from './session-manager'; export default class SessionTransport implements Transport { protected readonly deferredTransport: () => Transport; protected readonly sessionManager: SessionManager; constructor(deferredTransport: () => Transport, sessionManager: SessionManager); private getSessionMetadata; unary = AnyMessage, O extends Message = AnyMessage>(service: ServiceType, method: MethodInfo, signal: AbortSignal | undefined, timeoutMs: number | undefined, header: HeadersInit | undefined, message: PartialMessage, contextValues?: ContextValues): Promise>; stream = AnyMessage, O extends Message = AnyMessage>(service: ServiceType, method: MethodInfo, signal: AbortSignal | undefined, timeoutMs: number | undefined, header: HeadersInit | undefined, input: AsyncIterable>, contextValues?: ContextValues): Promise>; }