Server | telnet-rxjs

Hierarchy

ReplaySubject<Server>
- Server

Implements

Subscribable<Server>
SubscriptionLike

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new Server(options?: any): Server

Overrides ReplaySubject.__constructor
- Defined in src/server.ts:14
Parameters
- Default value options: any = {}
Returns Server

Properties

_isScalar

_isScalar: boolean

Internal implementation detail, do not use directly.

closed

closed: boolean

Private connections

connections: Connection[]

filter

filter: typeof filter

hasError

hasError: boolean

isStopped

isStopped: boolean

observers

observers: Observer<Server>[]

operator

operator: Operator<any, Server>

deprecated: This is an internal implementation detail, do not use.

Private options

options: any

Private server

server: Server | Server | undefined

source

source: Observable<any>

deprecated: This is an internal implementation detail, do not use.

thrownError

thrownError: any

Static create

create: Function

nocollapse
deprecated: use new Subject() instead

Static if

if: typeof iif

nocollapse
deprecated: In favor of iif creation function: import { iif } from 'rxjs';

Static throw

throw: typeof throwError

nocollapse
deprecated: In favor of throwError creation function: import { throwError } from 'rxjs';

Methods

_getNow

_getNow(): number

Inherited from Connection._getNow
- Defined in node_modules/rxjs/internal/ReplaySubject.d.ts:23
Returns number

_subscribe

_subscribe(subscriber: Subscriber<Server>): Subscription

Inherited from Connection._subscribe

Overrides Subject._subscribe
- Defined in node_modules/rxjs/internal/ReplaySubject.d.ts:22
deprecated

This is an internal implementation detail, do not use.

Parameters
- subscriber: Subscriber<Server>
Returns Subscription

_trySubscribe

_trySubscribe(subscriber: Subscriber<Server>): TeardownLogic

Inherited from Connection._trySubscribe

Overrides Observable._trySubscribe
- Defined in node_modules/rxjs/internal/Subject.d.ts:39
deprecated

This is an internal implementation detail, do not use.

Parameters
- subscriber: Subscriber<Server>
Returns TeardownLogic

asObservable

asObservable(): Observable<Server>

Inherited from Connection.asObservable
- Defined in node_modules/rxjs/internal/Subject.d.ts:48
Creates a new Observable with this Subject as the source. You can do this to create customize Observer-side logic of the Subject and conceal it from code that uses the Observable.

Returns Observable<Server>

Observable that the Subject casts to

complete

complete(): void

Inherited from Connection.complete
- Defined in node_modules/rxjs/internal/Subject.d.ts:36
Returns void

Private connectionFactory

connectionFactory(socket: Socket | TLSSocket): void

- Defined in src/server.ts:85
Parameters
- socket: Socket | TLSSocket
Returns void

error

error(err: any): void

Inherited from Connection.error
- Defined in node_modules/rxjs/internal/Subject.d.ts:35
Parameters
- err: any
Returns void

forEach

forEach(next: (value: Server) => void, promiseCtor?: PromiseConstructorLike): Promise<void>

Inherited from Connection.forEach
- Defined in node_modules/rxjs/internal/Observable.d.ts:64
method

forEach

Parameters
- next: (value: Server) => void
  
  a handler for each value emitted by the observable
  - - (value: Server): void
    - Parameters
      - value: Server
      Returns void
- Optional promiseCtor: PromiseConstructorLike
Returns Promise<void>

a promise that either resolves on observable completion or rejects with the handled error

lift

lift<R>(operator: Operator<Server, R>): Observable<R>

Inherited from Connection.lift

Overrides Observable.lift
- Defined in node_modules/rxjs/internal/Subject.d.ts:33
Type parameters
- R
Parameters
- operator: Operator<Server, R>
Returns Observable<R>

next(value?: T): void

Inherited from Connection.next
- Defined in node_modules/rxjs/internal/Subject.d.ts:34
Parameters
- Optional value: T
Returns void

pipe

pipe(): Observable<Server>
pipe<A>(op1: OperatorFunction<Server, A>): Observable<A>
pipe<A, B>(op1: OperatorFunction<Server, A>, op2: OperatorFunction<A, B>): Observable<B>
pipe<A, B, C>(op1: OperatorFunction<Server, A>, op2: OperatorFunction<A, B>, op3: OperatorFunction<B, C>): Observable<C>
pipe<A, B, C, D>(op1: OperatorFunction<Server, A>, op2: OperatorFunction<A, B>, op3: OperatorFunction<B, C>, op4: OperatorFunction<C, D>): Observable<D>
pipe<A, B, C, D, E>(op1: OperatorFunction<Server, A>, op2: OperatorFunction<A, B>, op3: OperatorFunction<B, C>, op4: OperatorFunction<C, D>, op5: OperatorFunction<D, E>): Observable<E>
pipe<A, B, C, D, E, F>(op1: OperatorFunction<Server, A>, op2: OperatorFunction<A, B>, op3: OperatorFunction<B, C>, op4: OperatorFunction<C, D>, op5: OperatorFunction<D, E>, op6: OperatorFunction<E, F>): Observable<F>
pipe<A, B, C, D, E, F, G>(op1: OperatorFunction<Server, A>, op2: OperatorFunction<A, B>, op3: OperatorFunction<B, C>, op4: OperatorFunction<C, D>, op5: OperatorFunction<D, E>, op6: OperatorFunction<E, F>, op7: OperatorFunction<F, G>): Observable<G>
pipe<A, B, C, D, E, F, G, H>(op1: OperatorFunction<Server, A>, op2: OperatorFunction<A, B>, op3: OperatorFunction<B, C>, op4: OperatorFunction<C, D>, op5: OperatorFunction<D, E>, op6: OperatorFunction<E, F>, op7: OperatorFunction<F, G>, op8: OperatorFunction<G, H>): Observable<H>
pipe<A, B, C, D, E, F, G, H, I>(op1: OperatorFunction<Server, A>, op2: OperatorFunction<A, B>, op3: OperatorFunction<B, C>, op4: OperatorFunction<C, D>, op5: OperatorFunction<D, E>, op6: OperatorFunction<E, F>, op7: OperatorFunction<F, G>, op8: OperatorFunction<G, H>, op9: OperatorFunction<H, I>): Observable<I>
pipe<A, B, C, D, E, F, G, H, I>(op1: OperatorFunction<Server, A>, op2: OperatorFunction<A, B>, op3: OperatorFunction<B, C>, op4: OperatorFunction<C, D>, op5: OperatorFunction<D, E>, op6: OperatorFunction<E, F>, op7: OperatorFunction<F, G>, op8: OperatorFunction<G, H>, op9: OperatorFunction<H, I>, ...operations: OperatorFunction<any, any>[]): Observable<{}>

Inherited from Connection.pipe
- Defined in node_modules/rxjs/internal/Observable.d.ts:77
Returns Observable<Server>
Inherited from Connection.pipe
- Defined in node_modules/rxjs/internal/Observable.d.ts:78
Type parameters
- A
Parameters
- op1: OperatorFunction<Server, A>
Returns Observable<A>
Inherited from Connection.pipe
- Defined in node_modules/rxjs/internal/Observable.d.ts:79
Type parameters
- A
- B
Parameters
- op1: OperatorFunction<Server, A>
- op2: OperatorFunction<A, B>
Returns Observable<B>
Inherited from Connection.pipe
- Defined in node_modules/rxjs/internal/Observable.d.ts:80
Type parameters
- A
- B
- C
Parameters
- op1: OperatorFunction<Server, A>
- op2: OperatorFunction<A, B>
- op3: OperatorFunction<B, C>
Returns Observable<C>
Inherited from Connection.pipe
- Defined in node_modules/rxjs/internal/Observable.d.ts:81
Type parameters
- A
- B
- C
- D
Parameters
- op1: OperatorFunction<Server, A>
- op2: OperatorFunction<A, B>
- op3: OperatorFunction<B, C>
- op4: OperatorFunction<C, D>
Returns Observable<D>
Inherited from Connection.pipe
- Defined in node_modules/rxjs/internal/Observable.d.ts:82
Type parameters
- A
- B
- C
- D
- E
Parameters
- op1: OperatorFunction<Server, A>
- op2: OperatorFunction<A, B>
- op3: OperatorFunction<B, C>
- op4: OperatorFunction<C, D>
- op5: OperatorFunction<D, E>
Returns Observable<E>
Inherited from Connection.pipe
- Defined in node_modules/rxjs/internal/Observable.d.ts:83
Type parameters
- A
- B
- C
- D
- E
- F
Parameters
- op1: OperatorFunction<Server, A>
- op2: OperatorFunction<A, B>
- op3: OperatorFunction<B, C>
- op4: OperatorFunction<C, D>
- op5: OperatorFunction<D, E>
- op6: OperatorFunction<E, F>
Returns Observable<F>
Inherited from Connection.pipe
- Defined in node_modules/rxjs/internal/Observable.d.ts:84
Type parameters
- A
- B
- C
- D
- E
- F
- G
Parameters
- op1: OperatorFunction<Server, A>
- op2: OperatorFunction<A, B>
- op3: OperatorFunction<B, C>
- op4: OperatorFunction<C, D>
- op5: OperatorFunction<D, E>
- op6: OperatorFunction<E, F>
- op7: OperatorFunction<F, G>
Returns Observable<G>
Inherited from Connection.pipe
- Defined in node_modules/rxjs/internal/Observable.d.ts:85
Type parameters
- A
- B
- C
- D
- E
- F
- G
- H
Parameters
- op1: OperatorFunction<Server, A>
- op2: OperatorFunction<A, B>
- op3: OperatorFunction<B, C>
- op4: OperatorFunction<C, D>
- op5: OperatorFunction<D, E>
- op6: OperatorFunction<E, F>
- op7: OperatorFunction<F, G>
- op8: OperatorFunction<G, H>
Returns Observable<H>
Inherited from Connection.pipe
- Defined in node_modules/rxjs/internal/Observable.d.ts:86
Type parameters
- A
- B
- C
- D
- E
- F
- G
- H
- I
Parameters
- op1: OperatorFunction<Server, A>
- op2: OperatorFunction<A, B>
- op3: OperatorFunction<B, C>
- op4: OperatorFunction<C, D>
- op5: OperatorFunction<D, E>
- op6: OperatorFunction<E, F>
- op7: OperatorFunction<F, G>
- op8: OperatorFunction<G, H>
- op9: OperatorFunction<H, I>
Returns Observable<I>
Inherited from Connection.pipe
- Defined in node_modules/rxjs/internal/Observable.d.ts:87
Type parameters
- A
- B
- C
- D
- E
- F
- G
- H
- I
Parameters
- op1: OperatorFunction<Server, A>
- op2: OperatorFunction<A, B>
- op3: OperatorFunction<B, C>
- op4: OperatorFunction<C, D>
- op5: OperatorFunction<D, E>
- op6: OperatorFunction<E, F>
- op7: OperatorFunction<F, G>
- op8: OperatorFunction<G, H>
- op9: OperatorFunction<H, I>
- Rest ...operations: OperatorFunction<any, any>[]
Returns Observable<{}>

Private serverNoTls

serverNoTls(hostUrl: Url): Server

- Defined in src/server.ts:73
Parameters
- hostUrl: Url
Returns Server

Private serverTls

serverTls(hostUrl: Url): Server

- Defined in src/server.ts:79
Parameters
- hostUrl: Url
Returns Server

start

start(): Promise<Server | Server>

- Defined in src/server.ts:22
Returns Promise<Server | Server>

stop

stop(): Promise<void>

- Defined in src/server.ts:51
Returns Promise<void>

subscribe(observer?: PartialObserver<Server>): Subscription
subscribe(next: null | undefined, error: null | undefined, complete: () => void): Subscription
subscribe(next: null | undefined, error: (error: any) => void, complete?: undefined | (() => void)): Subscription
subscribe(next: (value: Server) => void, error: null | undefined, complete: () => void): Subscription
subscribe(next?: undefined | ((value: Server) => void), error?: undefined | ((error: any) => void), complete?: undefined | (() => void)): Subscription

Inherited from Connection.subscribe
- Defined in node_modules/rxjs/internal/Observable.d.ts:47
Parameters
- Optional observer: PartialObserver<Server>
Returns Subscription
Inherited from Connection.subscribe
- Defined in node_modules/rxjs/internal/Observable.d.ts:49
deprecated

Use an observer instead of a complete callback

Parameters
- next: null | undefined
- error: null | undefined
- complete: () => void
  - - (): void
    - Returns void
Returns Subscription
Inherited from Connection.subscribe
- Defined in node_modules/rxjs/internal/Observable.d.ts:51
deprecated

Use an observer instead of an error callback

Parameters
- next: null | undefined
- error: (error: any) => void
  - - (error: any): void
    - Parameters
      - error: any
      Returns void
- Optional complete: undefined | (() => void)
Returns Subscription
Inherited from Connection.subscribe
- Defined in node_modules/rxjs/internal/Observable.d.ts:53
deprecated

Use an observer instead of a complete callback

Parameters
- next: (value: Server) => void
  - - (value: Server): void
    - Parameters
      - value: Server
      Returns void
- error: null | undefined
- complete: () => void
  - - (): void
    - Returns void
Returns Subscription
Inherited from Connection.subscribe
- Defined in node_modules/rxjs/internal/Observable.d.ts:54
Parameters
- Optional next: undefined | ((value: Server) => void)
- Optional error: undefined | ((error: any) => void)
- Optional complete: undefined | (() => void)
Returns Subscription

toPromise

toPromise<T>(this: Observable<T>): Promise<T>
toPromise<T>(this: Observable<T>, PromiseCtor: typeof Promise): Promise<T>
toPromise<T>(this: Observable<T>, PromiseCtor: PromiseConstructorLike): Promise<T>

Inherited from Connection.toPromise
- Defined in node_modules/rxjs/internal/Observable.d.ts:88
Type parameters
- T
Parameters
- this: Observable<T>
Returns Promise<T>
Inherited from Connection.toPromise
- Defined in node_modules/rxjs/internal/Observable.d.ts:89
Type parameters
- T
Parameters
- this: Observable<T>
- PromiseCtor: typeof Promise
Returns Promise<T>
Inherited from Connection.toPromise
- Defined in node_modules/rxjs/internal/Observable.d.ts:90
Type parameters
- T
Parameters
- this: Observable<T>
- PromiseCtor: PromiseConstructorLike
Returns Promise<T>

unsubscribe

unsubscribe(): void

Inherited from Connection.unsubscribe
- Defined in node_modules/rxjs/internal/Subject.d.ts:37
Returns void

Hierarchy

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

Default value options: any = {}

Returns Server

Properties

_isScalar

closed

Private connections

filter

hasError

isStopped

observers

operator

Private options

Private server

source

thrownError

Static create

Static if

Static throw

Methods

_getNow

Returns number

_subscribe

Parameters

subscriber: Subscriber<Server>

Returns Subscription

_trySubscribe

Parameters

subscriber: Subscriber<Server>

Returns TeardownLogic

asObservable

Returns Observable<Server>

complete

Returns void

Private connectionFactory

Parameters

socket: Socket | TLSSocket

Returns void

error

Parameters

err: any

Returns void

forEach

Parameters

next: (value: Server) => void

Parameters

value: Server

Returns void

Optional promiseCtor: PromiseConstructorLike

Returns Promise<void>

lift

Type parameters

R

Parameters

operator: Operator<Server, R>

Returns Observable<R>

next

Parameters

Optional value: T

Returns void

pipe

Returns Observable<Server>

Type parameters

A

Parameters

op1: OperatorFunction<Server, A>

Returns Observable<A>

Type parameters

A

B

Parameters

op1: OperatorFunction<Server, A>