From b26426214ec70a9d6a428c9fdba6dc32c4113b02 Mon Sep 17 00:00:00 2001 From: NIC Lin Date: Wed, 7 Aug 2019 11:43:32 +0800 Subject: [PATCH] Update libp2p/pubsub/pubsub.py Co-Authored-By: Kevin Mai-Husan Chia --- libp2p/pubsub/pubsub.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/libp2p/pubsub/pubsub.py b/libp2p/pubsub/pubsub.py index 75058e5f..d0dad89b 100644 --- a/libp2p/pubsub/pubsub.py +++ b/libp2p/pubsub/pubsub.py @@ -26,7 +26,9 @@ def get_msg_id(msg: rpc_pb2.Message) -> Tuple[bytes, bytes]: return (msg.seqno, msg.from_id) -ValidatorFn = Union[Callable[[ID, rpc_pb2.Message], bool], Awaitable[bool]] +SyncValidatorFn = Callable[[ID, rpc_pb2.Message], bool] +AsyncValidatorFn = Callable[[ID, rpc_pb2.Message], Awaitable[bool]] +ValidatorFn = Union[SyncValidatorFn, AsyncValidatorFn] TopicValidator = NamedTuple("TopicValidator", (("validator", ValidatorFn), ("is_async", bool)))