Skip to content

Commit

Permalink
added streaming redezvous type
Browse files Browse the repository at this point in the history
  • Loading branch information
Corvin Lasogga committed Aug 14, 2022
1 parent eda84c9 commit d252e71
Showing 1 changed file with 11 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@

"""Internal types."""

import abc
from typing import Dict, Iterator, TypeVar, Union

import grpc
Expand All @@ -27,3 +28,13 @@

ProtoMessageOrIterator = Union[ProtoMessage, Iterator[ProtoMessage]]
"""Type for a protobuf message or a iterator of protobuf messages."""


class StreamingRendezvous(
grpc.Call,
grpc.Future,
grpc.RpcError,
Iterator,
abc.ABC
):
"""Class for a streaming rendezvous."""

0 comments on commit d252e71

Please sign in to comment.