Stream | /http2/stream.ts | grpc_basic@0.4.7

class Stream

extends Duplex

import { Stream } from "https://deno.land/x/grpc_basic@0.4.7/http2/stream.ts";

Constructors

new

Stream(connection: Connection)

Properties

optional

_closedByUs: boolean

optional

_closedWithRst: boolean

optional

_ended: boolean

optional

_initiated: boolean

_letPeerPrioritize: boolean

_log

_priority

optional

_processedHeaders: boolean

_read: () => unknown

optional

_receiveMore: Function

_resetSent: boolean

optional

_sendMore: Function

_write: (

buffer: any,

encoding: string,

ready: Function,

) => unknown

connection: Connection

optional

id: number

sentEndStream: boolean

optional

state: string

optional

upstream: Flow

Methods

_finishing()

_initializeDataFlow()

_initializeManagement()

_initializeState()

_onData(frame: Frame)

_onHeaders(unnamed 0: Frame)

_onPriority(unnamed 0: Frame)

_onPromise(unnamed 0: Frame)

_onTrailers(frame: Frame)

_pushUpstream(frame: Partial<Frame>)

_receive(unnamed 0: Frame, ready: Function)

_send()

_setState(state: string)

_transition(sending: boolean, frame: any)

_writeUpstream(frame: Frame)

altsvc(

host: string,

port: number,

protocolID: string,

maxAge: number,

origin: string,

)

headers(headers: Record<string, string>)

priority(priority: number, peer: boolean)

promise(headers: Record<string, string>)

reset(error: string)

trailers(trailers: Record<string, string>)