Options
All
  • Public
  • Public/Protected
  • All
Menu

Class ServerGrpc

Hierarchy

Implements

  • any

Index

Constructors

constructor

  • Parameters

    • options: object
      • Optional credentials?: any
      • Optional loader?: object
        • Optional alternateCommentMode?: boolean
        • Optional arrays?: boolean
        • Optional bytes?: Function
        • Optional defaults?: boolean
        • Optional enums?: Function
        • Optional includeDirs?: string[]
        • Optional json?: boolean
        • Optional keepCase?: boolean
        • Optional longs?: Function
        • Optional objects?: boolean
        • Optional oneofs?: boolean
      • Optional maxReceiveMessageLength?: number
      • Optional maxSendMessageLength?: number
      • package: string
      • Optional protoLoader?: string
      • protoPath: string
      • Optional url?: string

    Returns ServerGrpc

Properties

Private grpcClient

grpcClient: any

Protected logger

logger: any = new Logger(Server.name)

Protected messageHandlers

messageHandlers: any = new Map<string, MessageHandler>()

Private options

options: object

Type declaration

  • Optional credentials?: any
  • Optional loader?: object
    • Optional alternateCommentMode?: boolean
    • Optional arrays?: boolean
    • Optional bytes?: Function
    • Optional defaults?: boolean
    • Optional enums?: Function
    • Optional includeDirs?: string[]
    • Optional json?: boolean
    • Optional keepCase?: boolean
    • Optional longs?: Function
    • Optional objects?: boolean
    • Optional oneofs?: boolean
  • Optional maxReceiveMessageLength?: number
  • Optional maxSendMessageLength?: number
  • package: string
  • Optional protoLoader?: string
  • protoPath: string
  • Optional url?: string

Private url

url: string

Methods

addHandler

  • addHandler(pattern: any, callback: MessageHandler, isEventHandler?: boolean): void

bindEvents

  • bindEvents(): Promise<void>

close

  • close(): void

Private collectDeepServices

  • collectDeepServices(name: string, grpcDefinition: any, accumulator: object[]): void
  • Recursively fetch all of the service methods available on loaded protobuf descriptor object, and collect those as an objects with dot-syntax full-path names.

    Example: for proto package Bundle.FirstService with service Events { rpc... will be resolved to object of (while loaded for Bundle package): { name: "FirstService.Events", service: {Object} }

    Parameters

    • name: string
    • grpcDefinition: any
    • accumulator: object[]

    Returns void

createClient

  • createClient(): any

createPattern

  • createPattern(service: string, methodName: string): string

createService

  • createService(grpcService: any, name: string): Promise<object>

createServiceMethod

  • createServiceMethod(methodHandler: Function, protoNativeHandler: any): Function

createStreamServiceMethod

  • createStreamServiceMethod(methodHandler: Function): Function

createUnaryServiceMethod

  • createUnaryServiceMethod(methodHandler: Function): Function

deserialize

  • deserialize(obj: any): any

getHandlerByPattern

getHandlers

getOptionsProp

  • getOptionsProp<T, K>(obj: T, prop: K, defaultValue?: T[K]): T[K]

getServiceNames

  • getServiceNames(grpcPkg: any): object[]
  • Will return all of the services along with their fully namespaced names as an array of objects. This method initiates recursive scan of grpcPkg object

    Parameters

    • grpcPkg: any

    Returns object[]

Protected handleError

  • handleError(error: string): void

handleEvent

  • handleEvent(pattern: string, packet: ReadPacket): Promise<any>

listen

  • listen(callback: function): Promise<void>

Protected loadPackage

  • loadPackage<T>(name: string, ctx: string, loader?: Function): T

loadProto

  • loadProto(): any

lookupPackage

  • lookupPackage(root: any, packageName: string): any

Private parseDeepServiceName

  • parseDeepServiceName(name: string, key: string): string

send

  • send(stream$: Observable<any>, respond: function): Subscription

start

  • start(callback?: function): Promise<void>

transformToObservable

  • transformToObservable<T>(resultOrDeffered: any): Observable<T>

Generated using TypeDoc