nga-30

.ts

@Injectable({
    providedIn: 'root',
})
export class ChatGrpcService {

    constructor(private client: ChatServicePromiseClient) {
    }

    public getChat(): Observable<ChatList.AsObject> {
        const req = new Stub();
        const meta: Metadata = grpcJwtMetadata();

        return grpcStream<ChatList.AsObject>(this.client.getChat(req, meta));
    }
}