Interface Protocol<T>

Generic interface for a medium that can have messages sent over channels

interface Protocol<T extends string = string> {
    receiveAll(channel: T): Observable<Serializable[]>;
    send(channel: T, ...data: Serializable[]): Promise<void>;
    sendAndReceive(
        channel: T,
        ...data: Serializable[],
    ): [sent: Promise<void>, received: Promise<Serializable[]>];
}

Type Parameters

T extends string = string

Index

Methods

receiveAll send sendAndReceive

Methods

receiveAll

receiveAll(channel: T): Observable<Serializable[]>
Parameters
- channel: T
Returns Observable<Serializable[]>
- Defined in libs/core/src/intermediary/protocol.ts:12

send

send(channel: T, ...data: Serializable[]): Promise<void>
Parameters
- channel: T
- ...data: Serializable[]
Returns Promise<void>
- Defined in libs/core/src/intermediary/protocol.ts:8

sendAndReceive

sendAndReceive(
channel: T,
...data: Serializable[],
): [sent: Promise<void>, received: Promise<Serializable[]>]
Parameters
- channel: T
- ...data: Serializable[]
Returns [sent: Promise<void>, received: Promise<Serializable[]>]
- Defined in libs/core/src/intermediary/protocol.ts:10