class PgConnImpl
implements PgConn
import { PgConnImpl } from "https://deno.land/x/pgc4d@v1.3.6/src/connection.ts";
Constructors
new
PgConnImpl(_options: ReturnType<computeOptions>, _conn: Deno.Conn)Properties
readonly
_channels: Map<string, { listeners: Set<NotificationListener>; subscribed: Deferred<void>; }>readonly
_reader: BufReaderreadonly
_syncMessage: Pipe<ServerMessage>readonly
_typeRegistry: TypeRegistryreadonly
_writer: BufWriterreadonly
done: Deferred<Error | undefined>Methods
_start()
addListener(channel: string, listener: NotificationListener): Promise<void>
close()
prepare(text: string)
query(text: string, params?: ColumnValue[])
queryStreaming(text: string, params?: ColumnValue[])
removeListener(channel: string, listener: NotificationListener): Promise<void>